RxJS - Hot Observable - Coding Blast - www.codingblast.com

rxjs-hot-observable.ts

import {Observable} from 'rxjs';

let source = Observable
    .interval(1000)
    .take(6)
    .publish()
    .refCount();


setTimeout(function () {
    source.subscribe(x => console.log('sub 1: ', x));
}, 2700);


setTimeout(function () {
    source.subscribe(x => console.log('                sub 2: ', x));
}, 4100);