RxJS代码未触发预期错误反而输出完成，是什么原因？

• subscriber的complete回调定义错误：你直接写了complete: console.log('complete!!')，代码执行到这一行时会立刻调用console.log打印内容，将返回值undefined赋值给complete字段，后续Observable运行到结束阶段时没有可执行的回调函数，所以你会提前看到complete!!的输出。
• filter运算不会抛出错误：JS 中字符串和数字做取余运算（'A' % 2）不会触发运行时错误，只会返回NaN，filter运算符会自动将NaN转为布尔值false，所以'A'会被直接过滤掉，不会触发error回调，整个流会正常跑完所有发射的值。

如果要实现你预期的「遇到非数字值触发error回调」的效果，调整代码如下：

const { of } = rxjs;
const { tap, filter } = rxjs.operators;

const obs$ = of(4, 8, 1, 14, 'A', 7);
const subscriber = {
    next: x => console.log(x),
    error: err => console.log('error:', err),
    // 改为函数形式，等待complete阶段触发时再执行
    complete: () => console.log('complete!!')
}

obs$
    .pipe(
        // 新增类型判断，遇到非数字主动抛出错误
        tap(x => {
            if (typeof x !== 'number') throw new Error(`无效值 ${x}：非数字类型`)
        }),
        filter(x => x % 2 === 0)
    )
    .subscribe(subscriber);

修正后代码运行时会先依次打印4、8、14，遇到'A'时抛出错误触发error回调，Observable直接终止，不会执行complete回调。

内容的提问来源于stack exchange，提问作者redchicken