OperationSkipWhile { public static <T> OnSubscribeFunc<T> skipWhileWithIndex(Observable<? extends T> source, Func2<? super T, Integer, Boolean> predicate) { return new SkipWhile<T>(source, predicate); }  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);  }
@Test public void testSkipWithIndex() { Observable<Integer> src = Observable.from(1, 2, 3, 4, 5); Observable.create(skipWhileWithIndex(src, INDEX_LESS_THAN_THREE)).subscribe(w); InOrder inOrder = inOrder(w); inOrder.verify(w, times(1)).onNext(4); inOrder.verify(w, times(1)).onNext(5); inOrder.verify(w, times(1)).onCompleted(); inOrder.verify(w, never()).onError(any(Throwable.class)); }