shareoperatorexample.ts

const observable = Rx.Observable  
      .interval(1000)
      .take(3)
      .publish()
      .refCount()

    const observerA = {
      next: (x) =>  console.log('A next ' + x) ,
      complete: () => console.log('A done')
    };

    const observerB = {
      next: (x) =>  console.log('B next ' + x) ,
      complete: () => console.log('B done')
    };

    observable.subscribe(observerA);

    setTimeout(() => {
      observable.subscribe(observerB);
    }, 4000)

    // Result will be 
    // A next 0
    // A next 1
    // A next 2
    // A done
    // B done