merge

merge

merge は、 複数の Observable が流す値を合流させて流す Observable を返す operator です。 並列度 (concurrency) を指定することができ、同時に流す Observable の数を制限できます。

const {merge, from} = require('rxjs');

const merge$ = merge(
    from('123'),
    from('456'),
    from('789'),
    2
);

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

1
2
3
4
5
6
7
8
9

参考