Searched refs:RxCancellable (Results 1 – 6 of 6) sorted by relevance
10 internal class RxCancellable(private val job: Job) : Cancellable { class
104 emitter.setCancellable(RxCancellable(job)) in asObservable()
55 subscriber.setCancellable(RxCancellable(coroutine)) in rxCompletable()
55 subscriber.setCancellable(RxCancellable(coroutine)) in rxSingle()
56 subscriber.setCancellable(RxCancellable(coroutine)) in rxMaybe()
65 …subscriber.setCancellable(RxCancellable(coroutine)) // do it first (before starting coroutine), to… in rxObservable()