combineLatest

combineLatest

combineLatest は、複数の Observable を取り、それぞれの Observable がnextするたびに最新の値をnextする Observable を返す operator です。

const {combineLatest, timer} = require('rxjs');

const timer1$ = timer(0, 1000);
const timer2$ = timer(500, 1000);

const combineLatest$ = combineLatest([timer1$, timer2$]);
combineLatest$.subscribe(([value1, value2]) => console.log([value1, value2]));

出力

[ 0, 0 ]
[ 1, 0 ]
[ 1, 1 ]
[ 2, 1 ]
[ 2, 2 ]
[ 3, 2 ]

参考