@Test public void testSkip1() { Observable<String> w = Observable.from("one", "two", "three"); Observable<String> skip = Observable.create(skip(w, 2)); @SuppressWarnings("unchecked") Observer<String> observer = mock(Observer.class); skip.subscribe(observer); verify(observer, never()).onNext("one"); verify(observer, never()).onNext("two"); verify(observer, times(1)).onNext("three"); verify(observer, never()).onError(any(Throwable.class)); verify(observer, times(1)).onCompleted(); }
public static <T> OnSubscribeFunc<T> skip(final Observable<? extends T> items, final int num) { return new OnSubscribeFunc<T>() { @Override public Subscription onSubscribe(Observer<? super T> observer) { return new Skip<T>(items, num).onSubscribe(observer); } }; }
OperationSkip { public static <T> OnSubscribeFunc<T> skip(final Observable<? extends T> items, final int num) { return new OnSubscribeFunc<T>() { @Override public Subscription onSubscribe(Observer<? super T> observer) { return new Skip<T>(items, num).onSubscribe(observer); } }; } }
OperationSkip { public static <T> OnSubscribeFunc<T> skip(final Observable<? extends T> items, final int num) { return new OnSubscribeFunc<T>() { @Override public Subscription onSubscribe(Observer<? super T> observer) { return new Skip<T>(items, num).onSubscribe(observer); } }; }  }
OperationSkip { public static <T> OnSubscribeFunc<T> skip(final Observable<? extends T> items, final int num) { return new OnSubscribeFunc<T>() { @Override public Subscription onSubscribe(Observer<? super T> observer) { return new Skip<T>(items, num).onSubscribe(observer); } }; }  static OnSubscribeFunc<T> skip(final Observable<? extends T> items, final int num); }
OperationSkip { public static <T> OnSubscribeFunc<T> skip(final Observable<? extends T> items, final int num) { return new OnSubscribeFunc<T>() { @Override public Subscription onSubscribe(Observer<? super T> observer) { return new Skip<T>(items, num).onSubscribe(observer); } }; }  static OnSubscribeFunc<T> skip(final Observable<? extends T> items, final int num);  }