使用RX (反应性扩展)创建20个延迟30毫秒的事件

Question

我想做一个快速爆发的火灾代码，可以叫我20次，每隔30毫秒一次。

这就是我迄今为止尝试过的：

Observable.Repeat(20).Delay(TimeSpan.FromMilliseconds(30)).Subscribe() 

对我来说，这似乎是合乎逻辑的解决方案，但我认为我的应用程序正在崩溃，因为它从未停止过。

如何使用UniRx实现这一点？https://rx.codeplex.com/

Answer 1

看起来你想要Observable.Interval和Observable.Take。

Observable.Interval(TimeSpan.FromMilliseconds(30)).Take(20)

此外，您所使用的方法并不是做您认为它们正在做的事情。在尝试之前，你应该先阅读文档。

• observable.Repeat(20)只是重复为每个订阅的观察者调用observer.OnNext(20)，永远。
• observable.Delay(TimeSpan.FromMilliseconds(30))只是在时间上将整个序列移动到30毫秒，而不是其他时间。