Observable函数未执行：需依次调用getData与getOtherData且不能用subscribe

看起来你踩了RxJS冷Observable的典型坑——你的数据流根本没被订阅，所以getData()完全没执行！RxJS里的冷Observable（比如HttpClient返回的）只有在被订阅的时候才会发起请求，你现在只是在myFunction里构建了流，但既没订阅它，也没把这个流返回给上层去订阅，自然tap里的代码不会执行。

加上你需要返回getOtherData()的结果，那我们来一步步修正：

问题核心分析 #

• 你没有返回构建好的Observable流，调用方无法触发订阅
• catchError里的写法有问题：of(tap(() => {}))是错误的，tap是操作符，不能直接放到of里，应该返回一个合法的Observable

修正后的代码 #

myFunction(): Observable<YourOtherDataType> { // 替换成getOtherData实际返回的类型
  return this.service.getData().pipe(
    tap(data => {
      doStuff(data); // 现在订阅后这里会正常执行
    }),
    switchMap(() => {
      return this.service.getOtherData().pipe(
        tap((data) => {
          sc.dispatch(new DoSomethingElse(data));
        }),
        catchError(err => {
          // 可选：添加错误日志或处理逻辑
          console.error('获取getOtherData失败:', err);
          // 返回合法Observable避免流中断，可根据需求返回默认值
          return of(null);
        })
      );
    })
  );
}

如何触发这个流？ #

现在myFunction返回了Observable，你需要在调用它的地方触发订阅：

// 比如在组件逻辑中
this.myFunction().subscribe({
  next: (result) => {
    // 这里可以拿到getOtherData的返回结果
  },
  error: (err) => {
    // 处理整个流的错误（比如getData请求失败的情况）
  }
});

如果是在Angular模板里，用async管道更省心（它会自动帮你完成订阅和取消订阅）：

{{ myFunction() | async }}

这样调整后，getData()会先执行，tap里的逻辑正常触发，然后切换到getOtherData()，同时你也能拿到它的返回结果，完全不用在myFunction里手动用subscribe阻塞逻辑。

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