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