| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/ |
| D | Channels.common.kt | 84 public suspend inline fun <E> BroadcastChannel<E>.consumeEach(action: (E) -> Unit): Unit = in consumeEach() method
173 public suspend inline fun <E> ReceiveChannel<E>.consumeEach(action: (E) -> Unit): Unit = in consumeEach() method
193 consumeEach { in consumeEachIndexed()
333 consumeEach { in first()
374 consumeEach { in firstOrNull()
395 consumeEach { in indexOf()
418 consumeEach { in indexOfFirst()
442 consumeEach { in indexOfLast()
492 consumeEach { in last()
519 consumeEach { in lastIndexOf()
[all …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxChannel.kt | 43 public suspend inline fun <T> MaybeSource<T>.consumeEach(action: (T) -> Unit): Unit = in consumeEach() method
44 openSubscription().consumeEach(action) in consumeEach()
48 public suspend inline fun <T> ObservableSource<T>.consumeEach(action: (T) -> Unit): Unit = in consumeEach() method
49 openSubscription().consumeEach(action) in consumeEach()
56 openSubscription().consumeEach(action) in consumeEach()
63 openSubscription().consumeEach(action) in consumeEach()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Channel.kt | 38 public suspend inline fun <T> Publisher<T>.consumeEach(action: (T) -> Unit): Unit = in consumeEach() method
39 openSubscription().consumeEach(action) in consumeEach()
46 openSubscription().consumeEach(action) in consumeEach()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/guide/ |
| D | example-select-03.kt | 25 side.consumeEach { println("Side channel has $it") } in <lambda>()
27 produceNumbers(side).consumeEach { in <lambda>()
|
| D | example-channel-03.kt | 17 squares.consumeEach { println(it) } in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxChannel.kt | 46 openSubscription().consumeEach(action) in collect()
53 openSubscription().consumeEach(action) in collect()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublisherAsFlowTest.kt | 143 channel.consumeEach { result.add(it) } in <lambda>()
170 channel.consumeEach { value -> in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ChannelsJvmTest.kt | 18 ch.consumeEach { sum += it } in testBlocking()
|
| D | ActorTest.kt | 140 channel.consumeEach { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | PublisherAsFlowTest.kt | 144 channel.consumeEach { result.add(it) } in <lambda>()
171 channel.consumeEach { value -> in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/ |
| D | IdFlowTest.kt | 60 channel.consumeEach { in <lambda>()
|
| D | FlowInvariantsTest.kt | 168 channel.consumeEach { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | BackpressureTest.kt | 51 channel.consumeEach { /* Do nothing, just consume elements */ } in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/ |
| D | ChannelBuildersFlowTest.kt | 260 channel.openSubscription().consumeEach { in testBroadcastAsFlowAsBroadcast()
264 channel.openSubscription().consumeEach { in testBroadcastAsFlowAsBroadcast()
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/ |
| D | ChannelSinkBenchmark.kt | 65 consumeEach { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/exceptions/ |
| D | StackTraceRecoveryChannelsTest.kt | 154 consumeEach { in <lambda>()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | ArrayChannelTest.kt | 188 channel.consumeEach { in checkBufferChannel()
|
| D | ArrayBroadcastChannelTest.kt | 174 sub.consumeEach { in <lambda>()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | ObservableAsFlowTest.kt | 182 channel.consumeEach { result.add(it) } in check()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/ |
| D | ReusableCancellableContinuationTest.kt | 33 channel.consumeEach { in testContinuationsCount()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | ObservableAsFlowTest.kt | 182 channel.consumeEach { result.add(it) } in check()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/api/ |
| D | kotlinx-coroutines-rx2.api | 17 …public static final fun consumeEach (Lio/reactivex/MaybeSource;Lkotlin/jvm/functions/Function1;Lko…
18 …public static final fun consumeEach (Lio/reactivex/ObservableSource;Lkotlin/jvm/functions/Function…
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/ |
| D | kotlinx-coroutines-reactive.api | 15 …public static final fun consumeEach (Lorg/reactivestreams/Publisher;Lkotlin/jvm/functions/Function…
|
| /external/kotlinx.coroutines/ |
| D | CHANGES.md | 320 * `consumeEach` is promoted to experimental API (#1080).
686 * `consume` or `consumeEach` extensions should be used for channels.
914 * `withLock` and `consumeEach` functions are now inline suspend functions.
1028 * Introduced `consumeEach` helper function for channels and reactive streams, Rx 1.x, and Rx 2.x.
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/api/ |
| D | kotlinx-coroutines-core.api | 641 …public static final fun consumeEach (Lkotlinx/coroutines/channels/BroadcastChannel;Lkotlin/jvm/fun…
642 …public static final fun consumeEach (Lkotlinx/coroutines/channels/ReceiveChannel;Lkotlin/jvm/funct…
|