console.clear();

​

​

let customer$ = new Rx.ReplaySubject(1);

​

getCustomer().subscribe(customer$);

​

customer$.subscribe(val => console.log('subscriber 1: ' + val));

​

setTimeout(() => {

  customer$.subscribe(val => console.log('subscriber 2: ' + val));  

}, 1000);

​

​

​

​

​

function getCustomer() {

  return new Rx.Observable(observer => {

    console.log('api request');

    setTimeout(() => {

      console.log('api response');

      observer.next('customer object');

      observer.complete();

    }, 500);

  });

}