OnSubscribeCombineLatestTest.java 文件源码

@Test
public void test1ToNSources() {
    int n = 30;
    FuncN<List<Object>> func = new FuncN<List<Object>>() {

        @Override
        public List<Object> call(Object... args) {
            return Arrays.asList(args);
        }
    };
    for (int i = 1; i <= n; i++) {
        System.out.println("test1ToNSources: " + i + " sources");
        List<Observable<Integer>> sources = new ArrayList<Observable<Integer>>();
        List<Object> values = new ArrayList<Object>();
        for (int j = 0; j < i; j++) {
            sources.add(Observable.just(j));
            values.add(j);
        }

        Observable<List<Object>> result = Observable.combineLatest(sources, func);

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

        result.subscribe(o);

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