Modern_Testing.java 文件源码

@Test
public void test_interval()
{
    TestScheduler testScheduler=new TestScheduler();
    Observable<Long>observable=Observable.interval(1, TimeUnit.SECONDS,testScheduler).take(5);
    TestObserver<Long> testObserver=new TestObserver<>();


    observable.subscribeOn(testScheduler).subscribe(testObserver);

    testObserver.assertNoValues();
    testObserver.assertNotComplete();
    testObserver.assertNoErrors();

    testScheduler.advanceTimeBy(1, TimeUnit.SECONDS);
    testObserver.assertValueCount(1);
    testObserver.assertValues(0l);

    testScheduler.advanceTimeTo(6, TimeUnit.SECONDS);
    testObserver.assertValueCount(5);
    testObserver.assertValues(0l,1l,2l,3l,4l);
}