c# - 使用 RX (Reactive Extensions) 创建 20 个延迟 30 毫秒的事件

Question

我想制作一个快速触发代码，它会以 30 毫秒的间隔调用我 20 次函数。

这是我到目前为止尝试过的:

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 毫秒。