触发一个事件并等待多个事件 RxTest

可以使用RxTest库中提供的TestScheduler来模拟触发一个事件并等待多个事件的场景。以下是一个示例代码：

import io.reactivex.Observable;
import io.reactivex.observers.TestObserver;
import io.reactivex.schedulers.TestScheduler;
import org.junit.Test;

import java.util.concurrent.TimeUnit;

public class RxTestExample {

    @Test
    public void testMultipleEvents() {
        TestScheduler testScheduler = new TestScheduler();
        TestObserver<Integer> testObserver = new TestObserver<>();

        // 创建一个被观察者，每隔1秒发射一个事件
        Observable<Integer> observable = Observable.interval(1, TimeUnit.SECONDS, testScheduler)
                .map(Long::intValue)
                .take(5);

        // 订阅观察者
        observable.subscribe(testObserver);

        // 触发事件
        testScheduler.advanceTimeBy(3, TimeUnit.SECONDS);

        // 断言观察者接收到的事件数量
        testObserver.assertValueCount(3);

        // 触发剩余的事件
        testScheduler.advanceTimeBy(2, TimeUnit.SECONDS);

        // 断言观察者接收到的事件数量
        testObserver.assertValueCount(5);

        // 断言观察者完成
        testObserver.assertComplete();
    }
}

在上面的示例中，我们使用TestScheduler来模拟时间的流逝。首先，我们创建了一个被观察者observable，它每隔1秒发射一个事件，总共发射5个事件。然后，我们订阅了观察者testObserver。接下来，我们通过调用testScheduler.advanceTimeBy()方法来模拟时间的流逝。在调用advanceTimeBy(3, TimeUnit.SECONDS)之后，观察者testObserver应该接收到3个事件。然后，我们再次调用advanceTimeBy(2, TimeUnit.SECONDS)来触发剩余的事件，观察者testObserver应该接收到5个事件。最后，我们使用assertValueCount()方法来断言观察者接收到的事件数量，并使用assertComplete()方法来断言观察者完成。

这样，我们就可以使用TestScheduler来触发一个事件并等待多个事件的场景，并使用TestObserver来验证观察者的行为。