0

我试图弄清楚如何使用外部订阅方法调用 2 个内部订阅方法。我总共想做 3 次 api 调用，但是，2 次 api 调用取决于 1 次 api 调用的结果。

this.subscription = this.quoteService //1st api call
    .get(this.quoteid)
    .pipe(
    switchMap((q: TradeinQuote) => {
        const quote = q["quote"];
        //execute code using quote
        this.price = quote["price"];
        this.retrieveDeviceid = quote["deviceid"];
        return this.faultService.get(this.retrieveDeviceid); //2nd api call
        }),
    ).subscribe(
        (faultGroup: FaultGroup[]) => {
        //execute logic for 2nd api call
    });
);

因此，在我从第一个 api 调用中获得 this.retrieveDeviceid 之后，我想再进行 2 个 api 调用，其中一个在 faultService 上（如图所示），第二个在 deviceService

E.g. this.deviceService.get(this.retrieveDeviceid)

目前显示的代码仅处理 1 个内部订阅和 1 个外部订阅。为了进行另一个内部订阅，我必须使用 mergeMap 或 forkJoin 吗？我该如何去做？感谢您的指导！！

4

1 回答 1

1

使用siwtchMap和forkJoin：

this.subscription = this.quoteService.get(this.quoteid).pipe(
  switchMap(response => forkJoin(
    of(response),
    this.faultService.get(response.quote.deviceid),
    this.deviceService.get(response.quote.deviceid),
  ))
).subscribe(([res1, res2, res3]) => { ... });

forkJoin结合冷可观察对象的结果（即不再发出值的可观察对象）。

编辑

要管理单个调用的某些逻辑，您可以使用tap：

this.subscription = this.quoteService.get(this.quoteid).pipe(
  tap(response => { /* execute some code with your first HTTP call response */ }),
  switchMap(response => forkJoin(
    of(response),
    this.faultService.get(response.quote.deviceid),
    this.deviceService.get(response.quote.deviceid),
  ))
).subscribe(([res1, res2, res3]) => { ... });
于 2019-01-14T10:13:52.827 回答