@Test public void testSkipLast1() { Observable<String> w = Observable.from("one", "two", "three"); Observable<String> observable = Observable.create(skipLast(w, 2)); @SuppressWarnings("unchecked") Observer<String> observer = mock(Observer.class); InOrder inOrder = inOrder(observer); observable.subscribe(observer); inOrder.verify(observer, never()).onNext("two"); inOrder.verify(observer, never()).onNext("three"); verify(observer, times(1)).onNext("one"); verify(observer, never()).onError(any(Throwable.class)); verify(observer, times(1)).onCompleted(); }
public static <T> OnSubscribeFunc<T> skipLast( Observable<? extends T> source, int count) { return new SkipLast<T>(source, count); }
OperationSkipLast { public static <T> OnSubscribeFunc<T> skipLast( Observable<? extends T> source, int count) { return new SkipLast<T>(source, count); } }
OperationSkipLast { public static <T> OnSubscribeFunc<T> skipLast( Observable<? extends T> source, int count) { return new SkipLast<T>(source, count); }  }
OperationSkipLast { public static <T> OnSubscribeFunc<T> skipLast( Observable<? extends T> source, int count) { return new SkipLast<T>(source, count); }  static OnSubscribeFunc<T> skipLast(
            Observable<? extends T> source, int count); }
OperationSkipLast { public static <T> OnSubscribeFunc<T> skipLast( Observable<? extends T> source, int count) { return new SkipLast<T>(source, count); }  static OnSubscribeFunc<T> skipLast(
            Observable<? extends T> source, int count);  }