Searched defs:cancellable (Results 1 – 7 of 7) sorted by relevance
315 … val cancellable = CancellableContinuationImpl(uCont.intercepted(), resumeMode = MODE_CANCELLABLE) in suspendCancellableCoroutine() constant333 val cancellable = getOrCreateCancellableContinuation(uCont.intercepted()) in suspendCancellableCoroutineReusable() constant
25 fun cancellable() = runBlocking { in <lambda>() method in benchmarks.tailcall.SimpleChannelBenchmark
23 public fun <T> SharedFlow<T>.cancellable(): Flow<T> = noImpl() in cancellable() method
257 public fun <T> Flow<T>.cancellable(): Flow<T> = in cancellable() method
912 Context.CancellableContext cancellable = blue.withCancellation(); in cancellableAncestorIntegrationTest() local927 Context.CancellableContext cancellable = Context.current().withCancellation(); in cancellableAncestorFork() local934 Context.CancellableContext cancellable = Context.current().withCancellation(); in cancellableContext_closeCancelsWithNullCause() local
67 private inline fun cancellable(done: Channel<Boolean>, block: () -> Unit) { in <lambda>() method in kotlinx.coroutines.channels.ChannelUndeliveredElementStressTest
72 bool cancellable; member