const Observable = Rx.Observable;

const Subject = Rx.Subject;

​

let subject = new Subject();

const response = {

  start_time: new Date(),

  end_time: new Date(),

  radio_show: {

    id: 0,

    name: "Loading..."

  }

};

​

let radioShow$ = Observable.defer(() => {

    // return http.get(...);

    return Observable.of(response);

  })

  .do(() => console.log('create new HTTP request'))

  .repeatWhen(() => subject)

  .publishReplay()

  .refCount();

​

// responses

radioShow$

  .startWith(response)

  .subscribe(val => console.log('Response:', val));

​

// pooling delay

radioShow$

  .map(response => { // calculate the delay

    // return response.end_time - (new Date()).getTime();

    return Math.random() * 1000;

  })

  .concatMap(delay => Observable.of(null).delay(delay))

  .subscribe(subject);

​