jjzjj

EventLoopScheduler

全部标签

c# - 在不跳过值的情况下节流 Rx.Observable

Throttle方法会在其他人跟随得太快时跳过可观察序列中的值。但我需要一种方法来延迟它们。也就是说,我需要在不跳过任何项的情况下设置项之间的最小延迟。实际例子:有一个网络服务接受请求的速度不超过每秒一次;有一个用户可以添加单个或批量的请求。如果没有Rx,我将创建一个列表和一个计时器。当用户添加请求时,我会将它们添加到列表中。在计时器事件中,我将检查列表是否为空。如果不是,我会发送请求并删除相应的项目。带锁和所有的东西。现在,使用Rx,我可以创建Subject,在用户添加请求时添加项目。但我需要一种方法来确保Web服务不会因应用延迟而被淹没。我是Rx的新手,所以我可能遗漏了一些明显的东