时间戳

首页 > 解决方案 > 如何在 rxjs 6.4.0 Angular 中替换 flatMap 和 mergeMap

angular - 如何在 rxjs 6.4.0 Angular 中替换 flatMap 和 mergeMap

问题描述

我的 Angular 7 应用程序中有一个拦截器，它在重新发出请求之前请求获取令牌。如果多个请求同时进入，那么它们都会发出获取令牌的请求。为了避免这种情况，我共享了一个 observable，以便共享获取令牌的结果，并且只发出一个请求来获取令牌。

我按如下方式创建共享的 observable

this.authService.sharedToken =   this.authService.getToken().pipe(share());

然后我提出请求

 return auth.sharedToken.flatMap((res) => {

     auth.saveTokenToLocalStorage(res);
     return this.getRequestWithAuthentication(request, next, auth);

 }).catch(function (err) {// I handle errors here
 }

问题是 flatMap 已被弃用，用 mergeMap 替换它也不起作用。似乎 mergeMap 现在是一个独立的功能。那么我怎样才能让上面的代码工作。

我正在使用 rxjs 6.4.0 和 Angular 7.2.4

谢谢。

编辑：

使用新的管道方法，我有以下内容：

  return auth.sharedToken.pipe(
            mergeMap((res) => {

                auth.saveTokenToLocalStorage(res);
                return this.getRequestWithAuthentication(request, next, auth);
            }), catchError(function (err) {
                console.log("failed to get token")
                return EMPTY;
            }));

当请求失败时，我无法打印“获取令牌失败”。我在那里做了更多的错误处理，所以我需要在请求失败时触发一些代码。

标签： angularrxjsrxjs6

解决方案

RxJS 5.5引入了新的管道运算符语法。在RxJS 6.0中，强制使用旧语法。因此，您必须将代码替换为

.pipe(
    mergeMap(...)
)

推荐阅读