Searched refs:disposableRef (Results 1 – 2 of 2) sorted by relevance
80 val disposableRef = AtomicReference<Disposable>() in <lambda>() constant83 … override fun onSubscribe(d: Disposable) { if (!disposableRef.compareAndSet(null, d)) d.dispose() } in <lambda>()95 awaitClose { disposableRef.getAndSet(Disposable.disposed())?.dispose() } in <lambda>()
80 val disposableRef = AtomicReference<Disposable>() in <lambda>() constant83 … override fun onSubscribe(d: Disposable) { if (!disposableRef.compareAndSet(null, d)) d.dispose() } in <lambda>()95 awaitClose { disposableRef.getAndSet(Disposables.disposed())?.dispose() } in <lambda>()