Searched refs:disposeOnCancellation (Results 1 – 10 of 10) sorted by relevance
26 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in <lambda>()57 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in await()76 override fun onSubscribe(d: Disposable) { cont.disposeOnCancellation(d) } in await()153 internal fun CancellableContinuation<*>.disposeOnCancellation(d: Disposable) = in awaitFirst() method
37 continuation.disposeOnCancellation(disposable) in asCoroutineDispatcher()
38 continuation.disposeOnCancellation(disposable.asDisposableHandle()) in asCoroutineDispatcher()
373 public fun CancellableContinuation<*>.disposeOnCancellation(handle: DisposableHandle): Unit = in removeOnCancellation() method
234 continuation.disposeOnCancellation(task) in scheduleResumeAfterDelay()
556 … cont.disposeOnCancellation(invokeOnCompletion(handler = ResumeOnCompletion(this, cont).asHandler)) in <lambda>()1230 … cont.disposeOnCancellation(invokeOnCompletion(ResumeAwaitOnCompletion(this, cont).asHandler)) in <lambda>()
434 emitter?.let { cont.disposeOnCancellation(it) } in emitSuspend()
86 …public static final fun disposeOnCancellation (Lkotlinx/coroutines/CancellableContinuation;Lkotlin…