Multicast-example2.ts

const connectableObservable = Rx.Observable  
      .interval(1000)
      .take(5)
      .multicast(new Rx.Subject());
    const observerA = {...};
    const observerB = {...};

    connectableObservable.connect();

    connectableObservable.subscribe(observerA); // first execution
    setTimeout(() => {
      connectableObservable.subscribe(observerB); // the same execution
    }, 2000);