RxJs combineLatest

combineLatest.ts

const oa = Rx.Observable.from(['a0', 'a1', 'a2']);
const ob = Rx.Observable.from(['b0', 'b1', 'b2', 'b3']);
const oc = Rx.Observable.from(['c0', 'c1', 'c2', 'c3']);

const r1 = oa
	.zip(Rx.Observable.interval(300), function(a, b) { return a; })

const r2 = ob
	.zip(Rx.Observable.interval(440), function(a, b) { return a; })

const r3 = oc
	.zip(Rx.Observable.interval(420), function(a, b) { return a; })

const listOfR = new Rx.Subject();

const u1 = Rx.Observable.combineLatest([r1]).subscribe(listOfR)
u1.unsubscribe()
const u2 = Rx.Observable.combineLatest([r1, r2]).subscribe(listOfR)
u2.unsubscribe()
Rx.Observable.combineLatest([r1, r2, r3]).subscribe(listOfR)

listOfR.do(console.log)

https://rxviz.com/v/7J2bbaJN