RxJs 5定期轮询无序清爽

问题描述：

我有以下代码（httpObservable在第一发射完成）以固定的“死时间”的民意调查服务：RxJs 5定期轮询无序清爽

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

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

答

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