@Test public void testDistinctUntilChangedWithComparatorAndKeySelectorandTwoSubscriptions() { Observable<String> src = Observable.from("a", "b", "x", "aa", "bb", "c", "ddd"); Observable.create(distinctUntilChanged(src, TO_UPPER_WITH_EXCEPTION, COMPARE_LENGTH)).subscribe(w); InOrder inOrder = inOrder(w); inOrder.verify(w, times(1)).onNext("a"); inOrder.verify(w, times(1)).onNext("x"); Observable.create(distinctUntilChanged(src, TO_UPPER_WITH_EXCEPTION, COMPARE_LENGTH)).subscribe(w2); inOrder.verify(w, times(1)).onNext("c"); inOrder.verify(w, times(1)).onNext("ddd"); inOrder.verify(w, times(1)).onCompleted(); inOrder.verify(w, never()).onNext(anyString()); verify(w, never()).onError(any(Throwable.class)); InOrder inOrder2 = inOrder(w2); inOrder2.verify(w2, times(1)).onNext("a"); inOrder2.verify(w2, times(1)).onNext("x"); inOrder2.verify(w2, times(1)).onNext("c"); inOrder2.verify(w2, times(1)).onNext("ddd"); inOrder2.verify(w2, times(1)).onCompleted(); inOrder2.verify(w2, never()).onNext(anyString()); verify(w2, never()).onError(any(Throwable.class)); }
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);  }