OperatorZipTest.java 文件源码

/**
 * Expect NoSuchElementException instead of blocking forever as zip should emit onComplete() and no onNext
 * and last() expects at least a single response.
 */
@Test(expected = NoSuchElementException.class)
public void testStartEmptyListBlocking() {

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

    o.toBlocking().last();
}