我有一个observeable，它正在监听数据库，并在添加到db时发出项。当我订阅这个observate时，它会一个接一个地发出已经存储在db中的项。我的问题是，我是否可以创建observable来收集以特定间隔（例如100毫秒）发射到列表中的项，并发射（或在某些函数中返回，例如doonnext）整个列表和单独的项（如果以更大的间隔发射）？提前谢谢！
ahy6op9u1#
您正在寻找缓冲区运算符：返回一个observable，该observable发出它从源observable收集的项的缓冲区。得到的可观察对象发出连接的、不重叠的缓冲区，每个缓冲区的持续时间由timespan参数指定。要每100毫秒发射一次收集的项目：
dbObservable .buffer(100, TimeUnit.MILLISECONDS) ... // here is your Lists
1条答案
按热度按时间ahy6op9u1#
您正在寻找缓冲区运算符：
返回一个observable，该observable发出它从源observable收集的项的缓冲区。得到的可观察对象发出连接的、不重叠的缓冲区，每个缓冲区的持续时间由timespan参数指定。
要每100毫秒发射一次收集的项目：