@Test public void testDistinctOfSourceWithExceptionsFromKeySelector() { Observable<String> src = Observable.from("a", "b", null, "c"); Observable.create(distinct(src, TO_UPPER_WITH_EXCEPTION)).subscribe(w); InOrder inOrder = inOrder(w); inOrder.verify(w, times(1)).onNext("a"); inOrder.verify(w, times(1)).onNext("b"); inOrder.verify(w, times(1)).onError(any(NullPointerException.class)); inOrder.verify(w, never()).onNext(anyString()); inOrder.verify(w, never()).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);  }