RxJs 5 定期轮询，无序刷新

Question

我有以下代码（httpObservable 在第一次发射时完成）用固定 "dead time" 轮询服务：

return serviceObservable.expand(() => Observable.timer(period).concatMap(() => serviceObservable));

如何使用每次重置计时器时发出的 Subject 制作计时器 "resettable"？

Answer 1

return serviceObservable
    .expand(() => Observable
        .timer(period)
        .race(subject.take(1))
        .concatMap(() => serviceObservable));

RxJs 5 定期轮询，无序刷新

RxJs 5 periodic polling with out of order refreshing

rxjs

rxjs5