为包含RxJava的throttleLast操作符的方法编写单元测试

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

import java.util.concurrent.TimeUnit;

public class MyRxJavaTest {

    private TestScheduler testScheduler;

    @Before
    public void setup() {
        testScheduler = new TestScheduler();
    }

    @Test
    public void testThrottleLast() {
        // 创建一个测试用的Observable
        Observable<Integer> observable = Observable.just(1, 2, 3, 4, 5)
                .throttleLast(100, TimeUnit.MILLISECONDS, testScheduler);

        // 创建一个测试观察者
        TestObserver<Integer> testObserver = observable.test();

        // 手动推进时间
        testScheduler.advanceTimeBy(100, TimeUnit.MILLISECONDS);

        // 断言结果
        testObserver.assertValues(1, 2, 3, 4, 5);
        testObserver.assertComplete();
    }
}