如何对并发rxjava执行进行单元测试

<dependency>
    <groupId>io.reactivex.rxjava2</groupId>
    <artifactId>rxjava</artifactId>
    <version>2.x.x</version>
</dependency>
<dependency>
    <groupId>io.reactivex.rxjava2</groupId>
    <artifactId>rxjava-test</artifactId>
    <version>2.x.x</version>
    <scope>test</scope>
</dependency>

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 RxJavaConcurrencyTest {

    @Test
    public void testConcurrency() {
        TestScheduler scheduler = new TestScheduler();

        Observable<Long> observable = Observable.interval(1, TimeUnit.SECONDS, scheduler)
                .take(5) // 只取前5个事件
                .map(i -> i * 10); // 对每个事件进行映射

        TestObserver<Long> observer = observable.test();

        scheduler.advanceTimeBy(5, TimeUnit.SECONDS); // 推进时间，模拟并发执行

        observer.assertValues(0L, 10L, 20L, 30L, 40L); // 验证预期的结果
        observer.assertComplete();
    }
}