Home
last modified time | relevance | path

Searched refs:ProducerScope (Results 1 – 23 of 23) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DProduce.kt17 public interface ProducerScope<in E> : CoroutineScope, SendChannel<E> { in <lambda>() interface
49 public suspend fun ProducerScope<*>.awaitClose(block: () -> Unit = {}) { in <lambda>()
97 @BuilderInference block: suspend ProducerScope<E>.() -> Unit in produce()
119 @BuilderInference block: suspend ProducerScope<E>.() -> Unit in produce()
130 @BuilderInference block: suspend ProducerScope<E>.() -> Unit in produce()
142 ) : ChannelCoroutine<E>(parentContext, channel, active = true), ProducerScope<E> {
DBroadcast.kt114 @BuilderInference block: suspend ProducerScope<E>.() -> Unit in broadcast()
130 ) : AbstractCoroutine<Unit>(parentContext, active), ProducerScope<E>, BroadcastChannel<E> by _chann… in <lambda>()
172 block: suspend ProducerScope<E>.() -> Unit
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/
DBuilders.kt265 public fun <T> channelFlow(@BuilderInference block: suspend ProducerScope<T>.() -> Unit): Flow<T> = in channelFlow()
331 public fun <T> callbackFlow(@BuilderInference block: suspend ProducerScope<T>.() -> Unit): Flow<T> … in channelFlow()
335 private val block: suspend ProducerScope<T>.() -> Unit, in channelFlow()
343 override suspend fun collectTo(scope: ProducerScope<T>) = in channelFlow()
351 private val block: suspend ProducerScope<T>.() -> Unit,
357 override suspend fun collectTo(scope: ProducerScope<T>) { in collectTo()
DChannels.kt139 override suspend fun collectTo(scope: ProducerScope<T>) = in receiveAsFlow()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/src/
DFlux.kt39 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in <lambda>()
54 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in flux()
61 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in flux()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxObservable.kt38 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in <lambda>()
53 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in rxObservable()
59 block: suspend ProducerScope<T>.() -> Unit in rxObservable()
74 ) : AbstractCoroutine<Unit>(parentContext, true), ProducerScope<T>, SelectClause2<T, SendChannel<T>…
DRxFlowable.kt37 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in rxFlowable()
52 @BuilderInference block: suspend ProducerScope<T>.() -> Unit
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DPublish.kt39 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in <lambda>()
54 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in publish()
63 block: suspend ProducerScope<T>.() -> Unit in publish()
83 ) : AbstractCoroutine<Unit>(parentContext, true), ProducerScope<T>, Subscription, SelectClause2<T, …
DReactiveFlow.kt111 override suspend fun collectTo(scope: ProducerScope<T>) = in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/
DRxObservable.kt35 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in <lambda>()
45 block: suspend ProducerScope<T>.() -> Unit in rxObservableInternal()
60 ) : AbstractCoroutine<Unit>(parentContext, true), ProducerScope<T>, SelectClause2<T, SendChannel<T>…
DRxFlowable.kt34 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in rxFlowable()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DChannelFlow.kt59 internal val collectToFun: suspend (ProducerScope<T>) -> Unit
108 protected abstract suspend fun collectTo(scope: ProducerScope<T>) in create()
168 protected override suspend fun collectTo(scope: ProducerScope<T>) = in collectTo()
DMerge.kt55 override suspend fun collectTo(scope: ProducerScope<T>) { in collectTo()
93 override suspend fun collectTo(scope: ProducerScope<T>) { in additionalToStringProps()
DFlowCoroutine.kt57 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in flowProduce()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/src/
DPublish.kt34 @BuilderInference block: suspend ProducerScope<T>.() -> Unit in flowPublish()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/
DREADME.md9 | [kotlinx.coroutines.reactive.publish] | `Publisher` | [ProducerScope] | C…
37 [ProducerScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corout…
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/
DREADME.md12 | [rxObservable] | `Observable` | [ProducerScope] | Cold observable th…
13 | [rxFlowable] | `Flowable` | [ProducerScope] | Cold observable th…
55 [ProducerScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corout…
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/
DREADME.md12 | [rxObservable] | `Observable` | [ProducerScope] | Cold observable th…
13 | [rxFlowable] | `Flowable` | [ProducerScope] | Cold observable th…
58 [ProducerScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.corout…
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DProduceTest.kt148 assertFailsWith<IllegalStateException> { (channel as ProducerScope<*>).awaitClose() } in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/
DREADME.md11 …[kotlinx.coroutines.channels.ReceiveChannel] | [ProducerScope][kotlinx.coroutines.channels.Produce…
125 [kotlinx.coroutines.channels.ProducerScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-co…
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/
DREADME.md11 …[kotlinx.coroutines.channels.ReceiveChannel] | [ProducerScope][kotlinx.coroutines.channels.Produce…
136 [kotlinx.coroutines.channels.ProducerScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-co…
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/
Dkotlinx-coroutines-reactive.api51 …e : kotlinx/coroutines/AbstractCoroutine, kotlinx/coroutines/channels/ProducerScope, kotlinx/corou…
/external/kotlinx.coroutines/kotlinx-coroutines-core/api/
Dkotlinx-coroutines-core.api775 …public static final fun awaitClose (Lkotlinx/coroutines/channels/ProducerScope;Lkotlin/jvm/functio…
776 …public static synthetic fun awaitClose$default (Lkotlinx/coroutines/channels/ProducerScope;Lkotlin…
783 public abstract interface class kotlinx/coroutines/channels/ProducerScope : kotlinx/coroutines/Coro…
1128 …protected abstract fun collectTo (Lkotlinx/coroutines/channels/ProducerScope;Lkotlin/coroutines/Co…