如何从Promise返回Observable<T>？函数返回值问题修复

你的代码问题在于：loginWithFacebook函数声明要返回Observable<AuthResult>，但函数本身没有返回任何值——你只是在fbService.login()的then回调里返回了Observable，这个返回值不会被外层函数捕获。

按照RxJS的异步流处理方式，你需要把Promise转换成Observable，并通过RxJS操作符串联逻辑，修改后的代码如下：

import { from } from 'rxjs';
import { switchMap, tap, shareReplay } from 'rxjs/operators';

// ...

public loginWithFacebook(): Observable<AuthResult> {
  // 将Facebook登录的Promise转为Observable
  return from(this.fbService.login()).pipe(
    // 用switchMap处理异步链式调用，获取token后调用后端登录接口
    switchMap((authResponse: any) => {
      const accessToken = authResponse.accessToken;
      return this.model.loginWithFacebook(accessToken);
    }),
    // 登录成功后设置会话
    tap(res => this.setSession(res)),
    // 共享订阅结果
    shareReplay()
  );
}

关键修改点： #

• 使用from()操作符把fbService.login()返回的Promise转换为Observable，让外层函数能直接返回符合类型要求的流
• 用RxJS的switchMap替代Promise的then来处理异步逻辑的串联，这是RxJS处理异步依赖的标准写法
• 整个操作链最终输出的就是AuthResult类型的Observable，完全匹配方法的返回值声明

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