@Test public void testSkipEverything() { Observable<Integer> src = Observable.from(1, 2, 3, 4, 3, 2, 1); Observable.create(skipWhile(src, LESS_THAN_FIVE)).subscribe(w); verify(w, never()).onNext(anyInt()); verify(w, never()).onError(any(Throwable.class)); verify(w, times(1)).onCompleted(); }
public static <T> OnSubscribeFunc<T> skipWhile(Observable<? extends T> source, final Func1<? super T, Boolean> predicate) { return new SkipWhile<T>(source, new Func2<T, Integer, Boolean>() { @Override public Boolean call(T value, Integer index) { return predicate.call(value); } }); }
OperationSkipWhile { public static <T> OnSubscribeFunc<T> skipWhile(Observable<? extends T> source, final Func1<? super T, Boolean> predicate) { return new SkipWhile<T>(source, new Func2<T, Integer, Boolean>() { @Override public Boolean call(T value, Integer index) { return predicate.call(value); } }); } }
OperationSkipWhile { public static <T> OnSubscribeFunc<T> skipWhile(Observable<? extends T> source, final Func1<? super T, Boolean> predicate) { return new SkipWhile<T>(source, new Func2<T, Integer, Boolean>() { @Override public Boolean call(T value, Integer index) { return predicate.call(value); } }); }  }
OperationSkipWhile { public static <T> OnSubscribeFunc<T> skipWhile(Observable<? extends T> source, final Func1<? super T, Boolean> predicate) { return new SkipWhile<T>(source, new Func2<T, Integer, Boolean>() { @Override public Boolean call(T value, Integer index) { return predicate.call(value); } }); }  static OnSubscribeFunc<T> skipWhileWithIndex(Observable<? extends T> source, Func2<? super T, Integer, Boolean> predicate); static OnSubscribeFunc<T> skipWhile(Observable<? extends T> source, final Func1<? super T, Boolean> predicate); }
OperationSkipWhile { public static <T> OnSubscribeFunc<T> skipWhile(Observable<? extends T> source, final Func1<? super T, Boolean> predicate) { return new SkipWhile<T>(source, new Func2<T, Integer, Boolean>() { @Override public Boolean call(T value, Integer index) { return predicate.call(value); } }); }  static OnSubscribeFunc<T> skipWhileWithIndex(Observable<? extends T> source, Func2<? super T, Integer, Boolean> predicate); static OnSubscribeFunc<T> skipWhile(Observable<? extends T> source, final Func1<? super T, Boolean> predicate);  }