@Test public void debounceSelectorObservableThrows() { PublishSubject<Integer> source = PublishSubject.create(); Func1<Integer, Observable<Integer>> debounceSel = new Func1<Integer, Observable<Integer>>() { @Override public Observable<Integer> call(Integer t1) { return Observable.error(new OperationReduceTest.CustomException()); } }; @SuppressWarnings("unchecked") Observer<Object> o = mock(Observer.class); source.debounce(debounceSel).subscribe(o); source.onNext(1); verify(o, never()).onNext(any()); verify(o, never()).onCompleted(); verify(o).onError(any(OperationReduceTest.CustomException.class)); }
public static <T> OnSubscribeFunc<T> debounce(Observable<T> items, long timeout, TimeUnit unit) { return debounce(items, timeout, unit, Schedulers.computation()); }
OperationDebounce { public static <T> OnSubscribeFunc<T> debounce(Observable<T> items, long timeout, TimeUnit unit) { return debounce(items, timeout, unit, Schedulers.computation()); } }
OperationDebounce { public static <T> OnSubscribeFunc<T> debounce(Observable<T> items, long timeout, TimeUnit unit) { return debounce(items, timeout, unit, Schedulers.computation()); }  }
OperationDebounce { public static <T> OnSubscribeFunc<T> debounce(Observable<T> items, long timeout, TimeUnit unit) { return debounce(items, timeout, unit, Schedulers.computation()); }  static OnSubscribeFunc<T> debounce(Observable<T> items, long timeout, TimeUnit unit); static OnSubscribeFunc<T> debounce(final Observable<T> items, final long timeout, final TimeUnit unit, final Scheduler scheduler); static OnSubscribeFunc<T> debounceSelector(
            Observable<? extends T> source,
            Func1<? super T, ? extends Observable<U>> debounceSelector); }
OperationDebounce { public static <T> OnSubscribeFunc<T> debounce(Observable<T> items, long timeout, TimeUnit unit) { return debounce(items, timeout, unit, Schedulers.computation()); }  static OnSubscribeFunc<T> debounce(Observable<T> items, long timeout, TimeUnit unit); static OnSubscribeFunc<T> debounce(final Observable<T> items, final long timeout, final TimeUnit unit, final Scheduler scheduler); static OnSubscribeFunc<T> debounceSelector(
            Observable<? extends T> source,
            Func1<? super T, ? extends Observable<U>> debounceSelector);  }