RxJs 5定期轮询无序清爽

Question

我有以下代码（httpObservable在第一发射完成）以固定的“死时间”的民意调查服务：

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

我怎样才能使计时器“复位”通过使用Subject哪个发出每次定时器应该重新设置？

Answer 1

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