| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/channels/ |
| D | Actor.kt | 115 ): SendChannel<E> { in actor()
149 SelectClause2<E, SendChannel<E>> {
175 override val onSend: SelectClause2<E, SendChannel<E>>
179 … registerSelectClause2(select: SelectInstance<R>, param: E, block: suspend (SendChannel<E>) -> R) { in registerSelectClause2()
|
| D | TickerChannels.kt | 81 channel: SendChannel<Unit> in fixedPeriodTicker()
104 channel: SendChannel<Unit> in fixedDelayTicker()
|
| D | Channels.kt | 19 public fun <E> SendChannel<E>.sendBlocking(element: E) { in sendBlocking()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxObservable.kt | 60 ) : AbstractCoroutine<Unit>(parentContext, true), ProducerScope<T>, SelectClause2<T, SendChannel<T>…
61 override val channel: SendChannel<T> get() = this
92 override val onSend: SelectClause2<T, SendChannel<T>>
97 …egisterSelectClause2(select: SelectInstance<R>, element: T, block: suspend (SendChannel<T>) -> R) { in registerSelectClause2()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxObservable.kt | 74 ) : AbstractCoroutine<Unit>(parentContext, true), ProducerScope<T>, SelectClause2<T, SendChannel<T>…
75 override val channel: SendChannel<T> get() = this
106 override val onSend: SelectClause2<T, SendChannel<T>>
111 …egisterSelectClause2(select: SelectInstance<R>, element: T, block: suspend (SendChannel<T>) -> R) { in registerSelectClause2()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/scheduler/actors/ |
| D | PingPongActorBenchmark.kt | 35 data class Letter(val message: Any?, val sender: SendChannel<Letter>)
65 pingChannel: SendChannel<PingPongActorBenchmark.Letter>, in CoroutineScope()
69 var initiator: SendChannel<PingPongActorBenchmark.Letter>? = null in CoroutineScope()
|
| D | StatefulActorBenchmark.kt | 42 data class Letter(val message: Any, val sender: SendChannel<Letter>)
81 …private fun CoroutineScope.requestorActor(computations: List<SendChannel<Letter>>, stopChannel: Ch… in requestorActor()
|
| D | CycledActorsBenchmark.kt | 70 var nextChannel: SendChannel<Letter>? = null in <lambda>()
91 …private fun createActor(nextActor: SendChannel<Letter>, stopChannel: Channel<Unit>) = actor<Letter… in <lambda>()
|
| D | ConcurrentStatefulActorBenchmark.kt | 86 computations: List<SendChannel<Letter>>, in requestorActorUnfair()
112 computations: List<SendChannel<Letter>>, in requestorActorFair()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/ |
| D | README.md | 12 …[actor][kotlinx.coroutines.channels.actor] | [SendChannel][kotlinx.coroutines.channels.SendCha…
36 | [Channel][kotlinx.coroutines.channels.Channel] | [send][kotlinx.coroutines.channels.SendChannel.…
60 …SendChannel][kotlinx.coroutines.channels.SendChannel] | [send][kotlinx.coroutines.channels.Send…
138 [kotlinx.coroutines.channels.SendChannel]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coro…
141 [kotlinx.coroutines.channels.SendChannel.send]: https://kotlin.github.io/kotlinx.coroutines/kotlinx…
143 [kotlinx.coroutines.channels.SendChannel.onSend]: https://kotlin.github.io/kotlinx.coroutines/kotli…
144 [kotlinx.coroutines.channels.SendChannel.offer]: https://kotlin.github.io/kotlinx.coroutines/kotlin…
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/ |
| D | README.md | 33 | [Channel][kotlinx.coroutines.channels.Channel] | [send][kotlinx.coroutines.channels.SendChannel.…
57 …SendChannel][kotlinx.coroutines.channels.SendChannel] | [send][kotlinx.coroutines.channels.Send…
127 [kotlinx.coroutines.channels.SendChannel.send]: https://kotlin.github.io/kotlinx.coroutines/kotlinx…
129 [kotlinx.coroutines.channels.SendChannel]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coro…
130 [kotlinx.coroutines.channels.SendChannel.onSend]: https://kotlin.github.io/kotlinx.coroutines/kotli…
131 [kotlinx.coroutines.channels.SendChannel.offer]: https://kotlin.github.io/kotlinx.coroutines/kotlin…
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Publish.kt | 83 …tine<Unit>(parentContext, true), ProducerScope<T>, Subscription, SelectClause2<T, SendChannel<T>> {
84 override val channel: SendChannel<T> get() = this
117 override val onSend: SelectClause2<T, SendChannel<T>>
122 …egisterSelectClause2(select: SelectInstance<R>, element: T, block: suspend (SendChannel<T>) -> R) { in registerSelectClause2()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | ConflatedBroadcastChannel.kt | 267 public override val onSend: SelectClause2<E, SendChannel<E>> in <lambda>()
268 get() = object : SelectClause2<E, SendChannel<E>> { in <lambda>()
269 … registerSelectClause2(select: SelectInstance<R>, param: E, block: suspend (SendChannel<E>) -> R) { in <lambda>()
274 …> registerSelectSend(select: SelectInstance<R>, element: E, block: suspend (SendChannel<E>) -> R) { in <lambda>()
|
| D | Channel.kt | 23 public interface SendChannel<in E> { interface
74 public val onSend: SelectClause2<E, SendChannel<E>> in send()
587 public interface Channel<E> : SendChannel<E>, ReceiveChannel<E> { in next()
|
| D | Produce.kt | 17 public interface ProducerScope<in E> : CoroutineScope, SendChannel<E> { in <lambda>()
25 public val channel: SendChannel<E> in <lambda>()
|
| D | Channels.common.kt | 811 public suspend inline fun <E, C : SendChannel<E>> ReceiveChannel<E>.filterIndexedTo(destination: C,… in filterIndexedTo()
884 public suspend fun <E : Any, C : SendChannel<E>> ReceiveChannel<E?>.filterNotNullTo(destination: C)… in filterNotNullTo()
924 public suspend inline fun <E, C : SendChannel<E>> ReceiveChannel<E>.filterNotTo(destination: C, pre… in filterNotTo()
964 public suspend inline fun <E, C : SendChannel<E>> ReceiveChannel<E>.filterTo(destination: C, predic… in filterTo()
1165 public suspend fun <E, C : SendChannel<E>> ReceiveChannel<E>.toChannel(destination: C): C { in toChannel()
1481 public suspend inline fun <E, R : Any, C : SendChannel<R>> ReceiveChannel<E>.mapIndexedNotNullTo(de… in mapIndexedNotNullTo()
1528 public suspend inline fun <E, R, C : SendChannel<R>> ReceiveChannel<E>.mapIndexedTo(destination: C,… in mapIndexedTo()
1588 public suspend inline fun <E, R : Any, C : SendChannel<R>> ReceiveChannel<E>.mapNotNullTo(destinati… in mapNotNullTo()
1630 public suspend inline fun <E, R, C : SendChannel<R>> ReceiveChannel<E>.mapTo(destination: C, transf… in mapTo()
|
| D | BroadcastChannel.kt | 27 public interface BroadcastChannel<E> : SendChannel<E> {
|
| D | AbstractChannel.kt | 21 ) : SendChannel<E> { in <lambda>()
370 final override val onSend: SelectClause2<E, SendChannel<E>> in <lambda>()
371 get() = object : SelectClause2<E, SendChannel<E>> { in <lambda>()
372 … registerSelectClause2(select: SelectInstance<R>, param: E, block: suspend (SendChannel<E>) -> R) { in <lambda>()
377 …> registerSelectSend(select: SelectInstance<R>, element: E, block: suspend (SendChannel<E>) -> R) { in <lambda>()
447 @JvmField val block: suspend (SendChannel<E>) -> R in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | CallbackFlowTest.kt | 15 private class CallbackApi(val block: (SendChannel<Int>) -> Unit) {
21 fun start(sink: SendChannel<Int>) { in start()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/ |
| D | SendingCollector.kt | 17 private val channel: SendChannel<T>
|
| D | Combine.kt | 109 (second as SendChannel<*>).invokeOnClose { in zipImpl()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-channel-07.kt | 21 suspend fun sendString(channel: SendChannel<String>, s: String, time: Long) { in sendString()
|
| D | example-select-03.kt | 12 fun CoroutineScope.produceNumbers(side: SendChannel<Int>) = produce<Int> { in <lambda>()
|
| /external/libchrome/mojo/core/ |
| D | broker_host.h | 36 bool SendChannel(PlatformHandle handle);
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | TestChannelKind.kt | 38 ): Channel<E>, SendChannel<E> by broadcast { in toString()
|