Hybrid-exmaple.ts

const observable = Rx.Observable.interval(1000).take(5);  
    const observerA = {...};
    const observerB = {...};

    const hybrid = {
      observers: [],
      subscribe: (obs) => {
        this.observers.push(obs);
      }
      next: (v) => {
        this.observers.forEach((o) => {
          o.next(v);
        })
      }
    }

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