使用 RxJs BehaviorSubject 在 Angular 拦截器中等待数据

Question

我是 rxjs 的新手 - 我了解大多数运算符，但我不了解 BehaviorSubject、filter 和 take 的特定用法。

我想在 Angular 拦截器中更新 oauth 访问和刷新令牌对。我在这里和博客中看到的所有代码都是相同的——似乎有一种标准的方法来做到这一点。但是有一点我不明白。

作为an example，这部分将请求排队，直到有新的访问和刷新令牌可用。

private refreshSubject = new BehaviorSubject<any>(null);

// ...etc.

if (!this.refreshInProgress) {
  // request new access and refresh tokens from server
  // populate refreshSubject once tokens received
}
else {
  return this.refreshSubject.pipe(
    filter(result => result !== null),                      // <---- ???
    take(1),                                                // <---- ???
    switchMap(() => next.handle(this.addToken(request)))
  );
}

所有此类示例都说明请求会排队，直到refreshSubject 被新令牌填充，而魔法发生在filter。

这是我不明白的。 rxjs docs 不是说 filter 导致等待 - 等待和排队在哪里/如何发生？

Answer 1

嗯，BehaviorSubject 的初始值为“NULL”（在进行获取新令牌的请求或套接字连接之前），您需要选择不同于 NULL 的值，为此我们使用“filter”运算符

filter(result => result !== null), 

这将仅将不同于 NULL 的值发送到 BehaviorSubject 的下一个管道步骤。

现在我们只需要“获取”一个从 BehaviorSubject 发出的值（由于获取新令牌的方式，您必须这样做），为了做到这一点，我们使用“take”运算符。

take(1),

这只会发出 ONE 值，即使有 10 个发出的值，也只有第一个会被传送到下一个管道步骤。

毕竟，您使用“switchMap”处理值，但请记住，每次获得新订阅时，BehaviorSubject 都会发出当前值（最后发出的值）。