Home
last modified time | relevance | path

Searched defs:consumeEach (Results 1 – 3 of 3) sorted by relevance

/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxChannel.kt43 public suspend inline fun <T> MaybeSource<T>.consumeEach(action: (T) -> Unit): Unit = in consumeEach() method
48 public suspend inline fun <T> ObservableSource<T>.consumeEach(action: (T) -> Unit): Unit = in consumeEach() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DChannel.kt38 public suspend inline fun <T> Publisher<T>.consumeEach(action: (T) -> Unit): Unit = in consumeEach() method
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DChannels.common.kt84 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