RxJava:如何刷新定时缓冲区？

Observable.interval(1, TimeUnit.SECONDS) // 每隔1秒发射一个递增的数字
    .buffer(10, TimeUnit.SECONDS) // 每隔10秒刷新一次缓冲区
    .subscribe(new Observer<List<Long>>() {
        @Override
        public void onSubscribe(Disposable d) {
            // 订阅时的操作
        }

        @Override
        public void onNext(List<Long> buffer) {
            // 处理每个缓冲区中的数据
            System.out.println("缓冲区中的数据：" + buffer);
        }

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

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