@Test
public void testDistinctUntilChangedOfNone() {

    Observable<String> src = Observable.empty();
    Observable.create(distinctUntilChanged(src)).subscribe(w);
    verify(w, never()).onNext(anyString());
    verify(w, never()).onError(any(Throwable.class));
    verify(w, times(1)).onCompleted();
}