const intervalOne$ = Rx.Observable.interval(1000); const intervalTwo$ = Rx.Observable.interval(2000); Rx.Observable.combineLatest( intervalOne$, intervalTwo$ ).subscribe(all => console.log(all));