【Rxjsワンポイント講座】mergeMapのconcurrentパラメータでプロセスの同時実行数を制限する

            import { interval, bufferCount } from 'rxjs';

//👇1秒間ごとにカウント数を流す
interval(1000).pipe(
   //👇指定した数だけ、流れてきた値をとり貯め、フルになったら逐次下流に流す
   bufferCount(3)
).subscribe(val =>
   console.log(val)
);
        

            [0,1,2] --> [3,4,5]  --> ...
        

            import { of, delay, mergeMap } from 'rxjs';

//👇数値を流す
const a$ = of(1,2,3,4,5,6,7,8,9,10).pipe(
   //👇何かしらの処理を想定...100ms遅延程度
   delay(100)
).subscribe(val =>
   console.log(val)
);

const b$ = of(1,2,3,4,5,6,7,8,9,10).pipe(
   //👇同時実行数を最大3に設定
   mergeMap(v => of(v), 3),
).subscribe(val =>
  console.log(val)
);