ngrx 效果中的 switchMap 取消选项 http 请求

Die*_*ega 4 xmlhttprequest rxjs ngrx-effects angular

我有一个这样的 ngrx 效果:

@Effect()
  throwError$: Observable<Action> = this.actions$.pipe(
    ofType<notificationActions.ErrorThrow>(
      notificationActions.ActionTypes.ThrowError
    ),
    tap(() => {
      this.store.dispatch(new masterActions.LoadingHide());
      this.sub = this.devTools.liftedState.subscribe(data => {
        this.errorLogService.addErrorLog(JSON.stringify(data)).subscribe(data2 => console.log('data2', data));
        console.log(JSON.stringify(data));
      });
    }),
    map(action => action.payload),
    tap(() => {
      this.sub.unsubscribe();
    }),
    mergeMap(error => {
      return of(
        new notificationActions.ErrorAdd({
          type: error.type,
          description: error.description
        })
      );
    })
  );
Run Code Online (Sandbox Code Playgroud)

errorLogService 的 addErrorLog 方法发送一个 http post 请求,将错误日志存储到数据库中。一切都在执行这样的请求,首先是选项请求,然后是发布请求,但是如果我切换到 switchMap 以组合两个可观察对象,则当我在 chrome 开发工具的网络选项卡上检查它时,选项请求将被取消。

这是重构的代码部分

tap(() => {
      this.store.dispatch(new masterActions.LoadingHide());
      this.sub = this.devTools.liftedState
        .pipe(
          switchMap(data => {
            console.log('data', data);
            return this.errorLogService.addErrorLog(JSON.stringify(data));
          })
        )
        .subscribe();
    })
Run Code Online (Sandbox Code Playgroud)

任何线索?

Mar*_*gen 6

我遇到了同样的问题。更换switchMapmergeMap没有对我来说,现在每个HTTP请求等待完成。

  • mergeMap 并行运行 Observables,而 switchMap 取消最后一次发出并切换到新的发出。这是一篇很好的读物:https://blog.angular-university.io/rxjs-higher-order-mapping/ (3认同)