@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);
}