Angular/TypeScript中如何让外部函数返回内部upload函数的执行结果？

你遇到的问题核心是嵌套订阅导致异步流断开：createTranscriptionJob没有等待getSasUrl和upload的异步操作完成，就直接返回了空的Observable。要让函数返回upload的执行结果，需要用RxJS的操作符把两个异步操作串联成一个完整的流，而不是用嵌套订阅。

修改后的代码 #

createTranscriptionJob(fileToUpload: File, language: string): Observable<void> {
  // 用pipe和switchMap串联两个Observable，替代嵌套订阅
  return this.getSasUrl(fileToUpload.name, language, ldapUserName)
    .pipe(
      switchMap(response => {
        // 拿到SAS URL后，返回upload的Observable
        return this.upload(response.sasUrl, fileToUpload);
      })
    );
}

关键修改点说明 #

1. 移除嵌套订阅：不再用subscribe处理getSasUrl的结果，而是用switchMap操作符——它会等待getSasUrl的异步操作完成，再自动订阅upload返回的Observable，并把upload的输出作为整个流的结果。
2. 直接返回串联后的流：函数不再返回空的of()，而是返回getSasUrl和upload串联后的完整Observable，这样调用方订阅这个函数的返回值时，就能等到upload执行完成的结果。

如果需要保留日志打印 #

如果想保留原来的console.log逻辑，可以在pipe里添加tap操作符（用于副作用处理，不影响流的输出）：

createTranscriptionJob(fileToUpload: File, language: string): Observable<void> {
  return this.getSasUrl(fileToUpload.name, language, ldapUserName)
    .pipe(
      switchMap(response => this.upload(response.sasUrl, fileToUpload)),
      tap(uploadResult => {
        // 打印upload的执行结果，void类型的话结果为undefined
        console.log(uploadResult);
      })
    );
}

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