Searched refs:AbstractCoroutine (Results 1 – 25 of 26) sorted by relevance
12
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/ |
| D | AbstractCoroutineTest.kt | 16 val coroutine = object : AbstractCoroutine<String>(coroutineContext, false) { in <lambda>()
56 … val coroutine = object : AbstractCoroutine<String>(coroutineContext + NonCancellable, false) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | ChannelCoroutine.kt | 15 ) : AbstractCoroutine<Unit>(parentContext, active), Channel<E> by _channel { in <lambda>()
|
| D | Broadcast.kt | 130 ) : AbstractCoroutine<Unit>(parentContext, active), ProducerScope<E>, BroadcastChannel<E> by _chann… in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/ |
| D | Builders.common.kt | 99 ) : AbstractCoroutine<T>(parentContext, active), Deferred<T>, SelectClause1<T> {
187 ) : AbstractCoroutine<Unit>(parentContext, active) { in invoke()
|
| D | AbstractCoroutine.kt | 35 public abstract class AbstractCoroutine<in T>( class
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/internal/ |
| D | Scopes.kt | 18 ) : AbstractCoroutine<T>(context, true), CoroutineStackFrame {
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxCompletable.kt | 42 ) : AbstractCoroutine<Unit>(parentContext, true) {
|
| D | RxMaybe.kt | 43 ) : AbstractCoroutine<T>(parentContext, true) {
|
| D | RxSingle.kt | 42 ) : AbstractCoroutine<T>(parentContext, true) {
|
| D | RxObservable.kt | 60 ) : AbstractCoroutine<Unit>(parentContext, true), ProducerScope<T>, SelectClause2<T, SendChannel<T>…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/native/src/ |
| D | Builders.kt | 56 ) : AbstractCoroutine<T>(parentContext, true) {
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxCompletable.kt | 56 ) : AbstractCoroutine<Unit>(parentContext, true) {
|
| D | RxMaybe.kt | 57 ) : AbstractCoroutine<T>(parentContext, true) {
|
| D | RxSingle.kt | 56 ) : AbstractCoroutine<T>(parentContext, true) {
|
| D | RxObservable.kt | 74 ) : AbstractCoroutine<Unit>(parentContext, true), ProducerScope<T>, SelectClause2<T, SendChannel<T>…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | JoinStrTest.kt | 81 (exceptionalJob as AbstractCoroutine<*>).cancelInternal(TestException1()) in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | SuppressionTests.kt | 19 val coroutine = object : AbstractCoroutine<String>(coroutineContext, false) { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Builders.kt | 66 ) : AbstractCoroutine<T>(parentContext, true) {
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/ |
| D | Mono.kt | 61 ) : AbstractCoroutine<T>(parentContext, true), Disposable {
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/ |
| D | kotlinx-coroutines-reactive.api | 35 …s kotlinx/coroutines/reactive/FlowSubscription : kotlinx/coroutines/AbstractCoroutine, org/reactiv…
51 …kotlinx/coroutines/reactive/PublisherCoroutine : kotlinx/coroutines/AbstractCoroutine, kotlinx/cor…
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/src/future/ |
| D | Future.kt | 51 ) : AbstractCoroutine<T>(context), BiConsumer<T?, Throwable?> {
|
| /external/kotlinx.coroutines/integration/kotlinx-coroutines-guava/src/ |
| D | ListenableFuture.kt | 280 ) : AbstractCoroutine<T>(context), Runnable {
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | ReactiveFlow.kt | 187 ) : Subscription, AbstractCoroutine<Unit>(context, true) {
|
| D | Publish.kt | 83 ) : AbstractCoroutine<Unit>(parentContext, true), ProducerScope<T>, Subscription, SelectClause2<T, …
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 449 * Reimplement `future` coroutine builders on top of `AbstractCoroutine` (#751).
752 * `AbstractCoroutine.onCancellation` is invoked before cancellation handler that is set via `invoke…
758 * Introduced stable public API for `AbstractCoroutine`:
943 …* Internal `AbstractCoroutine` class is refactored so that it is extended only by true coroutines,
|
12