Searched refs:Disposable (Results 1 – 22 of 22) sorted by relevance
8 import io.reactivex.disposables.Disposable in <lambda>()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()169 private lateinit var subscription: Disposable in toString()173 override fun onSubscribe(sub: Disposable) { in toString()
69 private val _subscription = atomic<Disposable?>(null) in consumeEach()77 override fun onSubscribe(sub: Disposable) { in consumeEach()
80 val disposableRef = AtomicReference<Disposable>() in <lambda>()83 … override fun onSubscribe(d: Disposable) { if (!disposableRef.compareAndSet(null, d)) d.dispose() } in <lambda>()
8 import io.reactivex.rxjava3.disposables.Disposable in <lambda>()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()169 private lateinit var subscription: Disposable in toString()173 override fun onSubscribe(sub: Disposable) { in toString()
80 val disposableRef = AtomicReference<Disposable>() in <lambda>()83 … override fun onSubscribe(d: Disposable) { if (!disposableRef.compareAndSet(null, d)) d.dispose() } in <lambda>()95 awaitClose { disposableRef.getAndSet(Disposable.disposed())?.dispose() } in <lambda>()
59 private val _subscription = atomic<Disposable?>(null) in collect()67 override fun onSubscribe(sub: Disposable) { in collect()
4 let litTaskProvider: vscode.Disposable | undefined;5 let customTaskProvider: vscode.Disposable | undefined;
8 import reactor.core.Disposable53 private fun Disposable.asDisposableHandle(): DisposableHandle = in Disposable() method
61 ) : AbstractCoroutine<T>(parentContext, true), Disposable {
3 import com.intellij.openapi.Disposable in <lambda>()24 private lateinit var testDisposable: Disposable in <lambda>()
124 var disposable: Disposable? = null in <lambda>()140 override fun onSubscribe(d: Disposable) { in <lambda>()
154 override fun onSubscribe(d: Disposable) { in <lambda>()187 override fun onSubscribe(d: Disposable) { in <lambda>()
10 import io.reactivex.rxjava3.disposables.Disposable132 val disposable = Disposable.empty() in testLateOnSubscribe()
232 var disposable: Disposable? = null in <lambda>()248 override fun onSubscribe(d: Disposable) { in <lambda>()
254 var disposable: Disposable? = null in <lambda>()270 override fun onSubscribe(d: Disposable) { in <lambda>()
3 import com.intellij.openapi.Disposable177 … override fun addRootSetChangedListener(p0: RootProvider.RootSetChangedListener, p1: Disposable) { in addRootSetChangedListener()
7 import com.intellij.openapi.Disposable in <lambda>()76 class AnalysisEnvironment(val messageCollector: MessageCollector) : Disposable { in <lambda>()
18 import com.intellij.openapi.Disposable;