RxJava 2：在一段时间后发出收集的项目列表

【问题标题】：RxJava 2: emit collected list of items after a certain period of timeRxJava 2：在一段时间后发出收集的项目列表
【发布时间】：2017-09-04 08:05:02
【问题描述】：

我有一个 Observable，它正在监听数据库并在添加到数据库时发出项目。当我订阅这个 observable 时，它会在 db 中一一发出快速的已存储项目。我的问题是我是否可以创建 observable 来收集以特定间隔（例如 100 毫秒）发射到列表中的项目并发射（或在某些函数中返回，例如 doOnNext）整个列表和单独的项目，如果发射更大间隔？

提前致谢！

【问题讨论】：

标签： java android rx-java rx-java2

【解决方案1】：

您正在寻找buffer运营商：

返回一个 Observable，它发出从源 Observable 收集的项的缓冲区。生成的 Observable 发出连接的、非重叠的缓冲区，每个缓冲区由 timespan 参数指定的固定持续时间。

每 100 毫秒发射一次收集的物品：

 dbObservable
     .buffer(100, TimeUnit.MILLISECONDS)
     ... // here is your Lists

【讨论】：

是的，我之前正在研究这种方法，但我的项目中的逻辑已经改变，我不再需要回答这个问题了。感谢您的时间和努力！