自上次事件以来，RxJava 忽略事件 X 时间？
刘大卫
我想知道是否有一种干净的方法来实现一个 observable 过滤掉在最近发出的事件之后的时间窗口内发生的任何事件？
我目前有这个：
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。相反，我想看看是否有一种方法可以组合可以做同样事情的 observable。
约斯里兹
似乎您的愿望行为正是throttleFirst()运算符：
它只会在每个时间窗口发出第一项。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
编辑于
相关文章
Related 相关文章
- 1
计算自上次事件以来经过的时间
- 2
如何在R中的不平衡面板数据中创建自上次事件以来的时间？
- 3
在熊猫中创建一个包含自上次事件以来的时间的新列
- 4
获取自上次事件以来的时间长度
- 5
自当前时间以来的事件日志
- 6
如何在wevtutil中使用xpath检索自特定时间以来的事件
- 7
计算 SQL 中每条记录自事件发生以来的滚动时间
- 8
R-计算自具有多个事件类型和ID的上一个事件以来经过的时间
- 9
将时间（事件）数组转换为时间 x 之前的事件数数组
- 10
R data.table：计数自上次发生以来的事件（多个，包括/不包括）
- 11
每当剩余时间等于X时触发事件
- 12
在Java中实现“自x以来的事件”的有效方法
- 13
在Java中实现“自x以来的事件”的有效方法
- 14
某些事件后rxjava interval（）重置时间
- 15
检查自日期以来经过的时间是否超过X天
- 16
如何获得自上次分裂以来的最后时间间隔？
- 17
自上次重启以来的时间：我该如何转换？
- 18
检查自上次点击以来的时间是否大于 2 秒
- 19
显示自上次 ajax 调用以来的时间
- 20
鼠标事件在底层被忽略
- 21
我的onclick事件被忽略
- 22
从上次在OS X中使用C修改文件以来获得时间？
- 23
计算事件之间的时间
- 24
熊猫时间事件研究
- 25
计算事件之间的时间
- 26
时间间隔事件支持
- 27
时间间隔事件
- 28
计算自Excel中的事件以来的天数
- 29
如何显示自上次使用“正常运行时间”启动系统以来经过的时间？
我来说两句