包含嵌套subs sink subscription的函数返回值为undefined如何解决

你遇到的是典型的异步逻辑与同步返回不匹配问题，具体原因如下：

• 你定义的getStudentDate是同步执行函数，而this.apiDataService.studyInfo返回的是RxJS Observable对象，subscribe中的回调是异步执行的，回调内部的return obj.Date只会把值返回到回调函数本身，不会作为外层getStudentDate的返回值，外层函数没有显式return自然返回undefined
• 你的代码还存在两处笔误：
  • 调用时的函数名getstudentDate（首字母s小写）和定义时的getStudentDate（首字母S大写）不匹配
  • 函数入参是Id，但构造请求参数objs时用了未定义的studyId变量

你可以根据自己的业务场景选择以下任意一种方案： #

方案1：返回Observable，调用方订阅（推荐，符合RxJS设计规范） #

修改getStudentDate函数，直接返回处理后的Observable，不要在内部订阅，保留你现有的subs sink订阅管理逻辑：

// 函数定义
getStudentDate(Id: string) { // 替换为你实际的Id类型
  const objs = {
    Id: Id // 修正studyId笔误
  }
  // 直接返回处理好的Observable，在pipe里做数据转换
  return this.apiDataService.studyInfo(objs).pipe(
    map(obj => obj.Date)
  )
}

调用时订阅接收值：

let studentDate: Date; // 替换为你实际的Date字段类型
this.subs.sink = this.getStudentDate(Id).subscribe(date => {
  this.studentDate = date;
  // 拿到studentDate后的所有后续业务逻辑都要写在这个回调里
})

方案2：通过回调函数传递结果 #

如果不想调整现有订阅管理逻辑，可以用回调方式拿到结果：

// 函数定义，新增回调参数
getStudentDate(Id: string, callback: (date: Date) => void) {
  const objs = {
    Id: Id
  }
  this.subs.sink = this.apiDataService.studyInfo(objs)
    .subscribe((obj) => {
      callback(obj.Date); // 拿到结果后触发回调
    })
}

调用方式：

let studentDate: Date;
this.getStudentDate(Id, (date) => {
  this.studentDate = date;
  // 后续业务逻辑写在回调里
})

方案3：转为Promise配合async/await #

如果你的场景更适合同步写法，可以把Observable转为Promise使用：

// 函数定义，返回Promise
import { firstValueFrom, map } from 'rxjs';
async getStudentDate(Id: string): Promise<Date> {
  const objs = {
    Id: Id
  }
  return firstValueFrom(
    this.apiDataService.studyInfo(objs).pipe(map(obj => obj.Date))
  )
}

调用时需要在外层async函数内执行：

// 注意调用getStudentDate的外层函数需要加async修饰
async yourCallingFunction() {
  this.studentDate = await this.getStudentDate(Id);
  // 后续业务逻辑写在await之后即可
}

提示：firstValueFrom是RxJS 7+提供的API，如果你用的是低版本RxJS可以暂时用toPromise()替代，更推荐升级到稳定版RxJS使用前者。

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