OperatorZipTest.java 文件源码

@Test
public void testStartEmptyList() {

    final Object invoked = new Object();
    Collection<Observable<Object>> observables = Collections.emptyList();

    Observable<Object> o = Observable.zip(observables, new FuncN<Object>() {
        @Override
        public Object call(final Object... args) {
            assertEquals("No argument should have been passed", 0, args.length);
            return invoked;
        }
    });

    TestSubscriber<Object> ts = new TestSubscriber<Object>();
    o.subscribe(ts);
    ts.awaitTerminalEvent(200, TimeUnit.MILLISECONDS);
    ts.assertReceivedOnNext(Collections.emptyList());
}