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.kt46 channel.invokeOnClose { in <lambda>()
64 channel.invokeOnClose { expect(2) } in <lambda>()
65 assertFailsWith<IllegalStateException> { channel.invokeOnClose { expect(3) } } in <lambda>()
73 channel.invokeOnClose { expect(3) } in <lambda>()
75 assertFailsWith<IllegalStateException> { channel.invokeOnClose { expect(4) } } in <lambda>()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/
DInvokeOnCloseStressTest.kt52 channel.invokeOnClose { counter.incrementAndGet() } in runStressTest()
57 channel.invokeOnClose { counter.incrementAndGet() } in runStressTest()
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/channels/
DProduce.kt53 invokeOnClose { in cont()
DChannel.kt142 public fun invokeOnClose(handler: (cause: Throwable?) -> Unit) in send() method
DConflatedBroadcastChannel.kt186 override fun invokeOnClose(handler: Handler) { in <lambda>() method in kotlinx.coroutines.channels.ConflatedBroadcastChannel
DAbstractChannel.kt266 override fun invokeOnClose(handler: Handler) { in <lambda>() method
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/internal/
DCombine.kt109 (second as SendChannel<*>).invokeOnClose { in zipImpl()
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/api/
Dkotlinx-coroutines-reactive.api57 public fun invokeOnClose (Lkotlin/jvm/functions/Function1;)Ljava/lang/Void;
58 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.kt71 override fun invokeOnClose(handler: (Throwable?) -> Unit) = in close() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/
DRxObservable.kt85 override fun invokeOnClose(handler: (Throwable?) -> Unit) = in close() method
/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/
DPublish.kt96 override fun invokeOnClose(handler: (Throwable?) -> Unit): Nothing = in close() method
/external/kotlinx.coroutines/kotlinx-coroutines-core/api/
Dkotlinx-coroutines-core.api766 public fun invokeOnClose (Lkotlin/jvm/functions/Function1;)V
812 public abstract fun invokeOnClose (Lkotlin/jvm/functions/Function1;)V
/external/kotlinx.coroutines/
DCHANGES.md614 * Introduced `SendChannel.invokeOnClose` (see #341).