@Test public void testDistinctOfNone() { Observable<String> src = Observable.empty(); Observable.create(distinct(src)).subscribe(w); verify(w, never()).onNext(anyString()); verify(w, never()).onError(any(Throwable.class)); verify(w, times(1)).onCompleted(); }
public static <T, U> OnSubscribeFunc<T> distinct(Observable<? extends T> source, Func1<? super T, ? extends U> keySelector) { return new Distinct<T, U>(source, keySelector); }
OperationDistinct { public static <T, U> OnSubscribeFunc<T> distinct(Observable<? extends T> source, Func1<? super T, ? extends U> keySelector) { return new Distinct<T, U>(source, keySelector); } }
OperationDistinct { public static <T, U> OnSubscribeFunc<T> distinct(Observable<? extends T> source, Func1<? super T, ? extends U> keySelector) { return new Distinct<T, U>(source, keySelector); }  }
OperationDistinct { public static <T, U> OnSubscribeFunc<T> distinct(Observable<? extends T> source, Func1<? super T, ? extends U> keySelector) { return new Distinct<T, U>(source, keySelector); }  static OnSubscribeFunc<T> distinct(Observable<? extends T> source, Func1<? super T, ? extends U> keySelector); static OnSubscribeFunc<T> distinct(Observable<? extends T> source, Comparator<T> equalityComparator); static OnSubscribeFunc<T> distinct(Observable<? extends T> source, Func1<? super T, ? extends U> keySelector, Comparator<U> equalityComparator); static OnSubscribeFunc<T> distinct(Observable<? extends T> source); }
OperationDistinct { public static <T, U> OnSubscribeFunc<T> distinct(Observable<? extends T> source, Func1<? super T, ? extends U> keySelector) { return new Distinct<T, U>(source, keySelector); }  static OnSubscribeFunc<T> distinct(Observable<? extends T> source, Func1<? super T, ? extends U> keySelector); static OnSubscribeFunc<T> distinct(Observable<? extends T> source, Comparator<T> equalityComparator); static OnSubscribeFunc<T> distinct(Observable<? extends T> source, Func1<? super T, ? extends U> keySelector, Comparator<U> equalityComparator); static OnSubscribeFunc<T> distinct(Observable<? extends T> source);  }