OperatorZipTest.java 文件源码

@SuppressWarnings("unchecked")
@Test
public void testCollectionSizeDifferentThanFunction() {
    FuncN<String> zipr = Functions.fromFunc(getConcatStringIntegerIntArrayZipr());
    //Func3<String, Integer, int[], String>

    /* define a Observer to receive aggregated events */
    Observer<String> observer = mock(Observer.class);

    @SuppressWarnings("rawtypes")
    Collection ws = java.util.Collections.singleton(Observable.just("one", "two"));
    Observable<String> w = Observable.zip(ws, zipr);
    w.subscribe(observer);

    verify(observer, times(1)).onError(any(Throwable.class));
    verify(observer, never()).onComplete();
    verify(observer, never()).onNext(any(String.class));
}