RxJava中的throttleLast与示例

Observable.create(new ObservableOnSubscribe<Integer>() {
    @Override
    public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
        // 模拟产生一系列事件
        for (int i = 1; i <= 10; i++) {
            emitter.onNext(i);
            Thread.sleep(100); // 模拟事件间隔
        }
        emitter.onComplete();
    }
})
.throttleLast(500, TimeUnit.MILLISECONDS) // 设置时间间隔为500毫秒
.subscribe(new Observer<Integer>() {
    @Override
    public void onSubscribe(Disposable d) {
        // 订阅时的操作
    }

    @Override
    public void onNext(Integer integer) {
        // 处理每个发射的事件
        System.out.println("onNext: " + integer);
    }

    @Override
    public void onError(Throwable e) {
        // 发生错误时的操作
    }

    @Override
    public void onComplete() {
        // 完成时的操作
    }
});