链接依赖的 observables

Question

我需要创建依赖 API 调用，其中第二个调用需要第一个返回的值。首先想到的是使用 flatMap

ApiManager.shared
    .createReport(report: report)
    .flatMap { (report) -> Observable<Report> in
        return ApiManager.shared.createReportStep(reportID: report.ID)
    }

createReport 返回Observable<Report>，其中调用成功后返回更新的Report 模型（带ID），之后我需要调用API 来创建报告步骤，其中需要report.ID。

该代码看起来一切正常，但当我需要在每个步骤之后执行某些操作时（createReport 和createReportStep）就会出现问题。我将代码放在onNext 块中，但是在两个步骤都完成后它只被调用一次。

有没有办法在两个步骤之后接收 onNext 信号？我可以使用这样的东西：

ApiManager.shared
      .createReport(report: report)
      .concat(ApiManager.shared.createReportStep(reportID: report.ID))

这会像我想要的那样发出两个信号，但是我又从哪里获得更新 report.ID 以传递到 createReportStep？

Answer 1

如果您不介意时间组件并且只需要访问report 和createReportStep(reportID:) 返回的内容，您可以在flatMap 的块中创建一个元组

ApiManager.shared
    .createReport(report: report)
    .flatMap { (report) -> Observable<Report> in
        return ApiManager.shared.createReportStep(reportID: report.ID)
            .map { (report, $0) }
    }

生成的 observable 将在一个元组中包含两个结果。

---

如果时间分量很重要，您可以执行以下操作

let report = ApiManager.shared
  .createReport(report: report)
  .share()

let reportStep = report.map { $0.ID }.flatMap(ApiManager.shared.createReportStep)

Observable.concat([report, reportStep])

这里，重要的是share 调用。它将确保createReport 只执行一次它的工作，但您将按照要求有两个下一个事件。