Home
last modified time | relevance | path

Searched refs:invokeOnClose (Results 1 – 14 of 14) sorted by relevance

/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/
DBasicOperationsTest.kt41 channel.invokeOnClose { in <lambda>()
59 channel.invokeOnClose { expect(2) } in <lambda>()
60 assertFailsWith<IllegalStateException> { channel.invokeOnClose { expect(3) } } in <lambda>()
68 channel.invokeOnClose { expect(3) } in <lambda>()
70 assertFailsWith<IllegalStateException> { channel.invokeOnClose { expect(4) } } in <lambda>()
91 ch.invokeOnClose { assertIs<CancellationException>(it) } in <lambda>()
98 ch.invokeOnClose { assertIs<TimeoutCancellationException>(it) } in <lambda>()
105 channel.invokeOnClose { in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/
DInvokeOnCloseStressTest.kt51 channel.invokeOnClose { counter.incrementAndGet() } in runStressTest()
56 channel.invokeOnClose { counter.incrementAndGet() } in runStressTest()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DProduce.kt49 invokeOnClose { in cont()
DChannel.kt142 public fun invokeOnClose(handler: (cause: Throwable?) -> Unit) in send() method
DBufferedChannel.kt1826 override fun invokeOnClose(handler: (cause: Throwable?) -> Unit) { in <lambda>() method in kotlinx.coroutines.channels.BufferedChannel
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DCombine.kt106 (second as SendChannel<*>).invokeOnClose { in zipImpl()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/
Dkotlinx-coroutines-reactive.api58 public fun invokeOnClose (Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
59 public synthetic fun invokeOnClose (Lkotlin/jvm/functions/Function1;)V
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/flow/channels/
DChannelFlowTest.kt47 invokeOnClose { in <lambda>()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/
DRxObservable.kt67 override fun invokeOnClose(handler: (Throwable?) -> Unit) = in close() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxObservable.kt67 override fun invokeOnClose(handler: (Throwable?) -> Unit) = in close() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DPublish.kt81 override fun invokeOnClose(handler: (Throwable?) -> Unit): Nothing = in close() method
/external/kotlinx.coroutines/
DCHANGES.md79 * `Channel.invokeOnClose` is promoted to stable API (#3358).
DCHANGES_UP_TO_1.7.md61 * `Channel.invokeOnClose` is promoted to stable API (#3358).
84 * `Channel.invokeOnClose` is promoted to stable API (#3358).
1064 * Introduced `SendChannel.invokeOnClose` (see #341).
/external/kotlinx.coroutines/kotlinx-coroutines-core/api/
Dkotlinx-coroutines-core.api836 public fun invokeOnClose (Lkotlin/jvm/functions/Function1;)V
890 public abstract fun invokeOnClose (Lkotlin/jvm/functions/Function1;)V