我想防止仅当在最近的x毫秒内发射了相同的精确项目时才发生发射。我已经查看了 throttle 和反跳操作器，但不确定它们是否可以帮助我。我可以使用另一个运算符，还是可以以某种方式组合它们？
最佳答案
您可以使用groupByUntil进行此操作，以实质上消除单个项目的反跳
o
.groupByUntil(x => x, x => x, x => Observable.timer(1000))
.flatMap(grp => grp.first())
我想防止仅当在最近的x毫秒内发射了相同的精确项目时才发生发射。我已经查看了 throttle 和反跳操作器，但不确定它们是否可以帮助我。我可以使用另一个运算符，还是可以以某种方式组合它们？
最佳答案
您可以使用groupByUntil进行此操作，以实质上消除单个项目的反跳
o
.groupByUntil(x => x, x => x, x => Observable.timer(1000))
.flatMap(grp => grp.first())