@Test
public void test5SourcesOverload() {
Observable<Integer> s1 = Observable.just(1);
Observable<Integer> s2 = Observable.just(2);
Observable<Integer> s3 = Observable.just(3);
Observable<Integer> s4 = Observable.just(4);
Observable<Integer> s5 = Observable.just(5);
Observable<List<Integer>> result = Observable.combineLatest(s1, s2, s3, s4, s5,
new Func5<Integer, Integer, Integer, Integer, Integer, List<Integer>>() {
@Override
public List<Integer> call(Integer t1, Integer t2, Integer t3, Integer t4, Integer t5) {
return Arrays.asList(t1, t2, t3, t4, t5);
}
});
@SuppressWarnings("unchecked")
Observer<Object> o = mock(Observer.class);
result.subscribe(o);
verify(o).onNext(Arrays.asList(1, 2, 3, 4, 5));
verify(o).onComplete();
verify(o, never()).onError(any(Throwable.class));
}
OnSubscribeCombineLatestTest.java 文件源码
java
阅读 27
收藏 0
点赞 0
评论 0
项目:RxJavaFlow
作者:
评论列表
文章目录