Для этого не обязательно использовать оператор.
Ниже приведен пример, где каждое четвертое значение будет ошибкой:
const observable$ = Observable.create(observer => {
let n = 1;
const intervalId = setInterval(() => {
if (n < 4) {
observer.next(n);
n += 1;
} else {
observer.error("Error emitted");
}
}, 1000);
return () => clearInterval(intervalId);
});
observable$.subscribe({
next: x => console.log(x),
error: x => console.error(x)
});
Однако, если вы ищете оператора, то throwError
может быть тем, который вы ищете. Подробности об этом можно найти здесь .