0

いくつかのオブザーバブルがあり、それらを 1 つに結合したいが、エラーを発生するものは無視したい。一部のオブザーバブルがエラーを発生した場合でも、オペレーターが成功したオブザーバブルの値を出力するようにしたい。

concat、forkJoin などの演算子を探していましたが、エラーが発生するとすぐに発行されます

import { concat, interval } from 'rxjs';
import { take } from 'rxjs/operators';

const timer1 = interval(1000).pipe(take(10));
const timer2 = interval(2000).pipe(take(6));
const timer3 = interval(500).pipe(take(10));

const result = concat(timer1, timer2, timer3);
result.subscribe(x => console.log(x));

// results in the following:
// (Prints to console sequentially)
// -1000ms-> 0 -1000ms-> 1 -1000ms-> ... 9
// -2000ms-> 0 -2000ms-> 1 -2000ms-> ... 5
// -500ms-> 0 -500ms-> 1 -500ms-> ... 9
4

1 に答える 1