Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
RxJS - Hot Observable - Coding Blast - www.codingblast.com
import {Observable} from 'rxjs';
let source = Observable
.interval(1000)
.take(6)
.publish();
source.connect();
setTimeout(function () {
source.subscribe(x => console.log('sub 1: ', x));
}, 2700);
setTimeout(function () {
source.subscribe(x => console.log(' sub 2: ', x));
}, 3700);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment