无法使用 RxJS 的 switchMap 获取第一个 HTTP 请求的结果

Question

我正在尝试发出 2 个 HTTP 请求，在第一次调用中我尝试创建一条记录，然后根据其结果（来自 API 方法的响应）我想执行或省略第二次调用来更新另一个数据。但是，虽然我可以在catchError 块中捕获错误，但我无法在第一次调用的 switchMap 方法中得到响应。那么，根据给定的场景，这个实现有什么问题呢？以及如何获得第一个结果的响应并根据第一个响应继续或不继续第二个调用？

let result;
let statusCode;

this.demoService.create(...).pipe(
    catchError((err: any) => { ... }),
    switchMap(response => {

    // I am trying to get the response of first request at here
    statusCode = response.statusCode;

    if(...){
        return this.demoService.update(...).pipe(
            catchError((err: any) => { ... }),
            map(response => {
            return {
                result: response
              }
          }
        )
      )}
    }
  ))
  .subscribe(result => console.log(result));

Answer 1

这个问题对我来说仍然很模糊。我将发布一个更通用的答案以澄清一些事情

有很多事情需要注意

1. 当一个 observable 发出 error 通知时，该 observable 被认为是关闭的（除非再次触发），并且不会触发以下依赖于 next 通知的运算符。如果您希望在switchMap 中捕获错误通知，您可以从catchError 返回一个next 通知。使用 RxJS of 函数的 catchError(error => of(error)) 之类的东西。然后通知将被以下switchMap 捕获。

2. 你必须从switchMap返回一个observable，不管你的情况如何。在这种情况下，如果您不希望在条件失败时返回任何内容，您可以返回 RxJS NEVER。但是，如果您希望发出可以被订阅 next 回调捕获的消息，您可以使用 RxJS of 函数。将return NEVER 替换为return of('Some message that will be emitted to subscription's next callback');

import { of, NEVER } from 'rxjs';
import { switchMap, catchError, map } from 'rxjs/operators';

this.demoService.create(...).pipe(
  catchError((err: any) => { ... }),
  switchMap(response => {
    statusCode = response.statusCode;

    if (someCondition) {
      return this.demoService.update(...).pipe(  // emit `update()` when `someCondition` passes
        catchError((err: any) => { ... }),
        map(response => ({ result: response }))
      );
    }
    // Show error message
    return NEVER;               // never emit when `someCondition` fails
  }
)).subscribe({
  next: result => console.log(result),
  error: error => console.log(error)
});

Answer 2

你可以用iif实现

this.demoService
   .create(...)
   .pipe(
     // tap first to be sure there's actually a response to process through
     tap(console.log),

     // You can use any condition in your iif, "response.user.exists" is just a sample
     // If the condition is true, it will run the run the update$ observable
     // If not, it will run the default$
     // NOTE: All of them must be an observable since you are inside the switchMap
     switchMap(response => 
      iif(() => 
        response.user.exists, 
        this.demoService.update(response.id),    // Pass ID 
        of('Default Random Message')
      )
     ),
     catchError((err: any) => { ... })
   );