@Test public void testWithEmpty3() { Observable<Boolean> observable = Observable.sequenceEqual( Observable.<String> empty(), Observable.<String> empty()); verifyResult(observable, true); }
public static <T> Observable<Boolean> sequenceEqual( Observable<? extends T> first, Observable<? extends T> second, final Func2<? super T, ? super T, Boolean> equality) { Observable<Object> firstObservable = materializeLite(first); Observable<Object> secondObservable = materializeLite(second); return zip(firstObservable, secondObservable, new Func2<Object, Object, Boolean>() { @Override @SuppressWarnings("unchecked") public Boolean call(Object t1, Object t2) { boolean c1 = t1 == LOCAL_ONCOMPLETED; boolean c2 = t2 == LOCAL_ONCOMPLETED; if (c1 && c2) { return true; } if (c1 || c2) { return false; } return equality.call((T)t1, (T)t2); } }).all(UtilityFunctions.<Boolean> identity()); }
OperatorSequenceEqual { public static <T> Observable<Boolean> sequenceEqual( Observable<? extends T> first, Observable<? extends T> second, final Func2<? super T, ? super T, Boolean> equality) { Observable<Object> firstObservable = materializeLite(first); Observable<Object> secondObservable = materializeLite(second); return zip(firstObservable, secondObservable, new Func2<Object, Object, Boolean>() { @Override @SuppressWarnings("unchecked") public Boolean call(Object t1, Object t2) { boolean c1 = t1 == LOCAL_ONCOMPLETED; boolean c2 = t2 == LOCAL_ONCOMPLETED; if (c1 && c2) { return true; } if (c1 || c2) { return false; } return equality.call((T)t1, (T)t2); } }).all(UtilityFunctions.<Boolean> identity()); } }
OperatorSequenceEqual { public static <T> Observable<Boolean> sequenceEqual( Observable<? extends T> first, Observable<? extends T> second, final Func2<? super T, ? super T, Boolean> equality) { Observable<Object> firstObservable = materializeLite(first); Observable<Object> secondObservable = materializeLite(second); return zip(firstObservable, secondObservable, new Func2<Object, Object, Boolean>() { @Override @SuppressWarnings("unchecked") public Boolean call(Object t1, Object t2) { boolean c1 = t1 == LOCAL_ONCOMPLETED; boolean c2 = t2 == LOCAL_ONCOMPLETED; if (c1 && c2) { return true; } if (c1 || c2) { return false; } return equality.call((T)t1, (T)t2); } }).all(UtilityFunctions.<Boolean> identity()); } private  OperatorSequenceEqual(); }
OperatorSequenceEqual { public static <T> Observable<Boolean> sequenceEqual( Observable<? extends T> first, Observable<? extends T> second, final Func2<? super T, ? super T, Boolean> equality) { Observable<Object> firstObservable = materializeLite(first); Observable<Object> secondObservable = materializeLite(second); return zip(firstObservable, secondObservable, new Func2<Object, Object, Boolean>() { @Override @SuppressWarnings("unchecked") public Boolean call(Object t1, Object t2) { boolean c1 = t1 == LOCAL_ONCOMPLETED; boolean c2 = t2 == LOCAL_ONCOMPLETED; if (c1 && c2) { return true; } if (c1 || c2) { return false; } return equality.call((T)t1, (T)t2); } }).all(UtilityFunctions.<Boolean> identity()); } private  OperatorSequenceEqual(); static Observable<Boolean> sequenceEqual(
            Observable<? extends T> first, Observable<? extends T> second,
            final Func2<? super T, ? super T, Boolean> equality); }
OperatorSequenceEqual { public static <T> Observable<Boolean> sequenceEqual( Observable<? extends T> first, Observable<? extends T> second, final Func2<? super T, ? super T, Boolean> equality) { Observable<Object> firstObservable = materializeLite(first); Observable<Object> secondObservable = materializeLite(second); return zip(firstObservable, secondObservable, new Func2<Object, Object, Boolean>() { @Override @SuppressWarnings("unchecked") public Boolean call(Object t1, Object t2) { boolean c1 = t1 == LOCAL_ONCOMPLETED; boolean c2 = t2 == LOCAL_ONCOMPLETED; if (c1 && c2) { return true; } if (c1 || c2) { return false; } return equality.call((T)t1, (T)t2); } }).all(UtilityFunctions.<Boolean> identity()); } private  OperatorSequenceEqual(); static Observable<Boolean> sequenceEqual(
            Observable<? extends T> first, Observable<? extends T> second,
            final Func2<? super T, ? super T, Boolean> equality);  }