我如何 - 长轮询和调度程序？

Question

我正在尝试安排一个长轮询机制。我想知道我是否可以为此利用调度程序。

这是我到目前为止的想法。

1. 通过计时器调度，但只有在上一次迭代已经完成时才将下一次迭代排入队列。

2. 在上一次迭代完成时将下一次迭代排入队列。

我一直在研究现有的调度程序，但我不确定该选择哪一个以及要重载什么。

最后但并非最不重要的一点——因为我是 Rx 世界的新手——相对于“自己动手”的方法，使用调度程序将提供哪些优势。

Answer 1

类似这样的：

Observable.interval(500)
.exhaustMap(() => this.load()) //previously flatMapFirst, creates new observable only if previous has ended
.map(r => resource.json)
.distinctUntilChanged() //optional tracking changes
.startWith(0);