java - RxJava 过期订阅

Question

我想对在特定时间范围内且仅发生一次的事件使用react。现在，代码如下所示:

mServiceRestartEmitter.take(1).subscribe(action);

但是，我希望该操作不仅在事件消耗 1 倍后取消订阅，而且如果事件没有在接下来的 300 毫秒内发生也取消订阅。如何实现这一目标？

Answer 1

刚刚意识到 take() 运算符也允许时间限制:

mServiceRestartEmitter.take(500, TimeUnit.MILLISECONDS).take(1).subscribeOn(Schedulers.io()).subscribe(action);

应该可以解决问题。