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