@Test @SuppressWarnings("unchecked") public void testNotAll() { Observable<String> obs = Observable.from("one", "two", "three", "six"); Observer<Boolean> observer = mock(Observer.class); Observable.create(all(obs, new Func1<String, Boolean>() { @Override public Boolean call(String s) { return s.length() == 3; } })).subscribe(observer); verify(observer).onNext(false); verify(observer).onCompleted(); verifyNoMoreInteractions(observer); }
public static <T> OnSubscribeFunc<Boolean> all(Observable<? extends T> sequence, Func1<? super T, Boolean> predicate) { return new AllObservable<T>(sequence, predicate); }
OperationAll { public static <T> OnSubscribeFunc<Boolean> all(Observable<? extends T> sequence, Func1<? super T, Boolean> predicate) { return new AllObservable<T>(sequence, predicate); } }
OperationAll { public static <T> OnSubscribeFunc<Boolean> all(Observable<? extends T> sequence, Func1<? super T, Boolean> predicate) { return new AllObservable<T>(sequence, predicate); }  }
OperationAll { public static <T> OnSubscribeFunc<Boolean> all(Observable<? extends T> sequence, Func1<? super T, Boolean> predicate) { return new AllObservable<T>(sequence, predicate); }  static OnSubscribeFunc<Boolean> all(Observable<? extends T> sequence, Func1<? super T, Boolean> predicate); }
OperationAll { public static <T> OnSubscribeFunc<Boolean> all(Observable<? extends T> sequence, Func1<? super T, Boolean> predicate) { return new AllObservable<T>(sequence, predicate); }  static OnSubscribeFunc<Boolean> all(Observable<? extends T> sequence, Func1<? super T, Boolean> predicate);  }