RxJava:如何对观察到的对象进行单元测试，并在正确的调度程序上进行订阅？

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

public class RxJavaUnitTest {

    @Test
    public void testObservable() {
        // 创建一个Observable对象
        Observable<String> observable = Observable.just("Hello", "World");

        // 创建一个TestObserver对象
        TestObserver<String> testObserver = new TestObserver<>();

        // 在正确的调度程序上进行订阅
        observable.subscribeOn(Schedulers.io())
                .observeOn(Schedulers.computation())
                .subscribe(testObserver);

        // 断言观察到的结果是否符合预期
        testObserver.assertValues("Hello", "World");
        testObserver.assertComplete();
    }
}