如何对Flowable.interval进行单元测试？

import io.reactivex.Flowable;
import io.reactivex.observers.TestObserver;
import org.junit.Test;

import java.util.concurrent.TimeUnit;

public class FlowableIntervalTest {

    @Test
    public void testFlowableInterval() {
        // 创建Flowable对象，每隔1秒发射一个递增的数字
        Flowable<Long> flowable = Flowable.interval(1, TimeUnit.SECONDS);

        // 创建观察者对象
        TestObserver<Long> testObserver = flowable.test();

        // 设置预期值的数量
        testObserver.assertValueCount(5);

        // 等待一段时间，以便Flowable发射完所有的数据
        testObserver.awaitTerminalEvent(6, TimeUnit.SECONDS);

        // 验证Flowable发射的数据是否符合预期
        testObserver.assertValues(0L, 1L, 2L, 3L, 4L);

        // 验证Flowable的完成状态
        testObserver.assertComplete();
    }
}