race

race

race は、複数の Observable を受け取り、それらの Observable で最初に値が流れた Observable の流れる値を流す Observable を返す operator です。 それ以外は無視されます。

const {race, interval} = require('rxjs');
const {mapTo} = require('rxjs/operators');

const race$ = race([
    interval(1000).pipe(mapTo('a')),
    interval(3000).pipe(mapTo('b')),
]);

race$.subscribe(
  value => console.log(value)
);

a
a
a
a
a
...

参考