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));