Agregaré mi respuesta ya que la respuesta de @ Maxime funciona, pero en realidad no hay necesidad de un sujeto .

Esto se hace usando el operador .concat() y la recursividad con la función getData() .

.concat()

Concatena múltiples Observables emitiendo secuencialmente sus valores, un Observable tras otro.

(...)

concat se suscribirá a la primera entrada Observable y emitirá todos sus valores, sin cambiarlos ni afectarlos de ninguna manera. Cuando ese Observable se complete, se suscribirá al siguiente Observable pasado y, nuevamente, emitirá sus valores. Esto se repetirá, hasta que el operador se quede sin Observables. Cuando se complete la última entrada de Observable, concat también se completará.

(Usé la versión js para hacer un fragmento que funciona con la herramienta Stack Overflow, pero esto es lo mismo para mecanografiado):

 function someHTTPCall() { // well it's a fake http call console.log("making the Http request (can take up to 5s)..."); return Rx.Observable.of("http response !") .delay(Math.round(Math.random() * 5000)); } function getData() { return someHTTPCall() .concat(Rx.Observable.timer(5000).switchMap(() => getData())); } let myObs = getData(); myObs.subscribe((data) => { console.log(data,"waiting for 5 seconds before next request"); });

 <script src="https://unpkg.com/rxjs@5.4.0/bundles/Rx.min.js"></script>

Esta es una pregunta interesante y me divertí un poco para encontrar una solución.

Esta solución espera a que la anterior termine como esperas:

 const { Observable, Subject } = Rx const getFakeHttpRequest$ = () => Observable.of('response !').delay(3000) const polling$ = new Subject() Observable // need to tick the first time .of(null) // everytime our polling$ subject will emit, we'll do again what's next .merge(polling$) // register to a fake request .switchMap(_ => getFakeHttpRequest$() .do(_ => { // once we're here, the request is done // no mater how long it was to get a response ... console.log('HTTP request done !'); // ... we wait 5s and then send a new value to polling$ subject // in order to trigger a new request setTimeout(_ => polling$.next(null), 5000) }) ) .subscribe()

Tenga en cuenta que puse un retraso de 3 segundos en la solicitud, y que se activa una nueva solicitud cada 8 segundos, ya que esperamos la respuesta durante 3 segundos y luego 5 segundos como lo solicitó en su pregunta.

Aquí hay un Plunkr en funcionamiento: https://plnkr.co/edit/kXefUbPleqyyUOlfwGuO?p=info

puedes usar el operador de intervalo:

 private poller(): Observable<PrepareData> { return Observable.interval(5000).switchMap(() => this.http.get("/cgi/dashboard.php")).map(res => res.json()); }