OperatorCompareTest.java 文件源码

@Test
public void testCompareOperatorInitialValue() throws Exception {
    @SuppressWarnings("unchecked") rx.Observer<Integer> observer = mock(rx.Observer.class);

    Observable<Integer> observable = Observable.just(1, 2, 3);

    OperatorCompare<Integer, Integer> operatorCompare = new OperatorCompare<Integer, Integer>(10, new Func2<Integer, Integer, Integer>() {
        @Override
        public Integer call(Integer integer, Integer integer2) {
            return integer + integer2;
        }
    });

    observable.lift(operatorCompare).subscribe(observer);

    verify(observer, never()).onError(any(Throwable.class));
    verify(observer, times(1)).onNext(11);
    verify(observer, times(1)).onNext(3);
    verify(observer, times(1)).onNext(5);
    verify(observer, times(1)).onCompleted();
}