OnSubscribeCombineLatestTest.java 文件源码

@Test
public void testZeroSources() {
    Observable<Object> result = Observable.combineLatest(Collections.<Observable<Object>> emptyList(), new FuncN<Object>() {

        @Override
        public Object call(Object... args) {
            return args;
        }

    });

    @SuppressWarnings("unchecked")
    Observer<Object> o = mock(Observer.class);

    result.subscribe(o);

    verify(o).onComplete();
    verify(o, never()).onNext(any());
    verify(o, never()).onError(any(Throwable.class));

}