Promise reject回调未触发但resolve回调正常执行问题排查

核心问题出在两个层面：

1. Promise链断裂/错误被中间层吞掉
   你业务侧调用的是changeStuff()方法，而非直接调用贴出来的load()方法。90%的场景下是changeStuff()内部没有正确传递Promise状态：
   • 要么是调用this.load()时没有加return或者await，导致load()返回的Promise变成独立的“浮动Promise”，它的reject状态不会传递到changeStuff()返回的Promise上；
   • 要么是changeStuff()内部写了try/catch捕获了load()的错误，但是捕获之后没有重新throw错误，直接把错误吞掉了，导致changeStuff()返回的Promise始终是成功状态，外层的catch回调自然不会触发。
2. RxJS逻辑存在缺陷，会导致Promise状态提前锁定
   你写的RxJS管道本身有问题，很容易出现reject调用无效的情况：
   • 操作符顺序错误：take(2)放在了filter前面，会直接取isReady$发射的前2个任意值（不管ready字段是不是true）。如果前2个值里包含多个ready=true的信号，会多次触发switchMap重新执行加载流程，很可能第一次加载已经触发resolve()把Promise状态改为成功，后续加载失败调用reject()会直接失效——Promise的状态一旦从pending变为成功/失败就不可逆，后续的resolve/reject调用都会被直接忽略。
   • 手动包装Promise的写法鲁棒性极差：你手动在new Promise的executor里订阅流，既没有处理流提前完成的场景（比如take(2)取到的2个值都不满足ready=true，流直接结束，Promise会永远卡在pending状态），也没有处理取消逻辑，容易造成内存泄漏。

第一步：修正库侧加载逻辑 #

抛弃手动嵌套包装Promise的写法，用RxJS官方提供的firstValueFrom做流转Promise，同时修正操作符顺序：

import { firstValueFrom } from 'rxjs';
import { filter, take, switchMap, tap } from 'rxjs/operators';

public async load(): Promise<void> {
  const loadStream$ = this.service.isReady$.pipe(
    // 先过滤出就绪状态，再取值
    filter(result => result.ready),
    // 只需要第一个就绪信号就启动加载，不需要take(2)，避免重复触发
    take(1),
    switchMap(() => this.loadClassifierFiles()),
    tap(() => {
      console.log('Classifier Files should load now');
    })
  );

  try {
    await firstValueFrom(loadStream$);
    // 这里放原subscribe.next里的业务逻辑
  } catch (err) {
    // 统一抛出错误，不要在这一层吞错
    throw new Error(
      err instanceof Error 
        ? err.message 
        : 'Could not fetch all Classifier Files from Destination'
    );
  }
}

第二步：检查changeStuff方法的逻辑 #

确保changeStuff()不会吞掉错误：

• 如果changeStuff()不需要对加载错误做特殊处理，直接返回load()的调用结果即可，不要额外包不必要的try/catch；
• 如果必须在changeStuff()内部做错误日志等处理，catch到错误之后一定要重新抛出，才能让外层业务侧的catch捕获到：

public async changeStuff(config: any) {
  try {
    await this.load();
    // 其他changeStuff的业务逻辑
  } catch (err) {
    console.error('加载失败', err);
    // 必须重新抛出错误，否则外层拿不到失败状态
    throw err;
  }
}

修正后业务侧现有调用代码不需要做任何改动，就可以正常触发成功/失败的回调逻辑。

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