Searched refs:setCancellable (Results 1 – 12 of 12) sorted by relevance
35 subscriber.setCancellable(RxCancellable(coroutine)) in rxCompletableInternal()
36 subscriber.setCancellable(RxCancellable(coroutine)) in rxMaybeInternal()
35 subscriber.setCancellable(RxCancellable(coroutine)) in rxSingleInternal()
128 emitter.setCancellable(RxCancellable(job)) in asObservable()
49 …subscriber.setCancellable(RxCancellable(coroutine)) // do it first (before starting coroutine), to… in rxObservableInternal()
49 subscriber.setCancellable(RxCancellable(coroutine)) in rxCompletable()
50 subscriber.setCancellable(RxCancellable(coroutine)) in rxMaybe()
49 subscriber.setCancellable(RxCancellable(coroutine)) in rxSingle()
63 …subscriber.setCancellable(RxCancellable(coroutine)) // do it first (before starting coroutine), to… in rxObservable()
151 public Options setCancellable(boolean allow) { in setCancellable() method in Interpreter.Options
655 new Interpreter(MODEL_BUFFER, new Interpreter.Options().setCancellable(true)); in testCancelInference()