java - RxJava 自上次事件以来忽略 X 时间的事件？

Question

我想知道是否有一种干净的方法来实现一个可观察对象，它可以过滤掉在最近发出的事件之后的时间窗口内发生的任何事件？

我目前有这个:

    source.timeInterval(TimeUnit.MILLISECONDS)
            .filter(new Predicate<Timed<Object>>() {
                final long TIME_LIMIT = 10 * 1000;
                long totalTime = 0;

                @Override
                public boolean test(@NonNull Timed<Object> objectTimed) throws Exception {
                    totalTime += objectTimed.time();

                    if (totalTime > TIME_LIMIT) {
                        totalTime = 0;
                        return true;
                    }
                    return false;
                }
            })
            .subscribe(objectTimed -> {
                doSomething(objectTimed)
            });

这在技术上可以解决问题，但需要在过滤器中添加一些额外的状态，这有点难看并且阻止我使用 lambda。相反，我想看看是否有一种方法可以编写可执行相同操作的可观察对象。

Answer 1

似乎您的期望行为正是 throttleFirst() 运算符:

它只会在每个时间窗口发出第一个项目。