RxJava 2：在一段时间后发出收集的项目列表
我有一个可观察的，它正在监听数据库，并在将其添加到数据库时发出项。当我订阅这个可观察对象时，它会一个接一个地发出快速存储在db中的项目。我的问题是，我是否可以创建observable来收集以特定间隔（例如100毫秒）发射到列表中的项目，并发射（或在某些函数中返回，如doOnNext）整个列表和单独的项目（如果以更大的间隔发射）？
提前感谢！
共有1个答案
您正在寻找缓冲区运算符：
要每100毫秒发射一次收集的项目，请执行以下操作：
dbObservable
.buffer(100, TimeUnit.MILLISECONDS)
... // here is your Lists
-
我很难理解以下代码示例的行为； 代码正常工作，直到调用观察到128项。发射和观察是平行的。但在那之后，Flowable继续发射项目（显然在某处排队），但直到所有1000个项目发射完毕，才观察到任何项目。发射完所有1000个项目后，剩下的项目( 这看起来与128的背压缓冲区大小有关，但我仍然希望发射和观察在整个1000个项目中是平行的，因为观察者显然不比发射者慢。我有什么遗漏吗？我应该怎么做来修复代
-
本文向大家介绍sharepoint项目。使用列表项目收集位置检索项目，包括了sharepoint项目。使用列表项目收集位置检索项目的使用技巧和注意事项，需要的朋友参考一下 示例
-
如果我对如何使用RxJava2缺乏基本的了解，请提前道歉，因为在我看来，这应该是非常基本的东西。我已经因为不成功的Google搜索而绞尽脑汁，所以欢迎任何资源推荐。为了清晰起见，我选择使用解决方法代码的“净化”表示。 我有一个RxJava2函数，它返回一个
-
我有一个使用Activity认可的Detected活动广播接收器。我注意到它确实连接了，但我没有得到任何数据。这是在三星Note 2上。在其他手机上，我尝试过它总是有效的。这是连接到谷歌api的代码： 这是请求动作的代码： 其中“GetActivityDetectionPendingContent”是： 奇怪的是，我然后重新启动了手机。进入应用程序，重新启动后，我只是稍微摇晃了一下手机，开始获取位
-
我有一个Java应用程序，它使用Prometheus库，以便在执行期间收集度量。稍后，我将Prometheus服务器链接到Grafana，以便可视化这些度量。我想知道是否可以让格拉法纳为这些度量显示一个自定义的X轴？通常的X轴是在当地时间。我能让它显示带有GPS/UTC时间戳的数据吗？有可能吗？如果是，需要什么？保存时间戳的附加度量参数？ 我这样声明度量变量： 并添加如下所示的数据： 如有任何帮助
-
我正在用OpenFL开发一个android游戏。当我在手机上测试它时，它启动得很好。现在，如果我停用游戏应用程序，并在短时间后返回它，它显示黑屏不到一秒钟，然后返回游戏。 然而，如果游戏应用程序在后台停留大约10分钟，那么如果我再次打开它，它就会显示黑屏，然后游戏在等待15秒之后就会出现，或者它根本就不会出现--只是一个黑屏。（至此，既然我可以下拉通知栏，android就没有冻结了。） 游戏中也有