Searched defs:cancellable (Results 1 – 9 of 9) sorted by relevance
427 … val cancellable = CancellableContinuationImpl(uCont.intercepted(), resumeMode = MODE_CANCELLABLE) in suspendCancellableCoroutine() constant445 val cancellable = getOrCreateCancellableContinuation(uCont.intercepted()) in suspendCancellableCoroutineReusable() constant
79 GCancellable* cancellable, in RequestSessionProxy()94 GCancellable* cancellable, in SetupSessionRequestHandlers()134 GCancellable* cancellable, in StartSessionRequest()167 GCancellable* cancellable, in TearDownSession()
25 GCancellable* cancellable = nullptr; member
21 fun cancellable() = runBlocking { in <lambda>() method
19 public fun <T> SharedFlow<T>.cancellable(): Flow<T> = noImpl() in cancellable() method
253 public fun <T> Flow<T>.cancellable(): Flow<T> = in cancellable() method
961 Context.CancellableContext cancellable = blue.withCancellation(); in cancellableAncestorIntegrationTest() local976 Context.CancellableContext cancellable = Context.current().withCancellation(); in cancellableAncestorFork() local983 Context.CancellableContext cancellable = Context.current().withCancellation(); in cancellableContext_closeCancelsWithNullCause() local
64 private inline fun cancellable(done: Channel<Boolean>, block: () -> Unit) { in <lambda>() method in kotlinx.coroutines.channels.ChannelUndeliveredElementSelectOldStressTest
64 private inline fun cancellable(done: Channel<Boolean>, block: () -> Unit) { in <lambda>() method in kotlinx.coroutines.channels.ChannelUndeliveredElementStressTest