时间戳

首页 > 解决方案 > rxjs - 是否有一个 always 运算符？你怎么总是做某事？

angular - rxjs - 是否有一个 always 运算符？你怎么总是做某事？

问题描述

我有一个 NGRX 效果（大量使用 RxJS），如下所示：

@Effect()
allFiltersRequested$ = this.actions$.pipe(
  ofType<AllFiltersRequestedAction>(FiltersActionTypes.AllFiltersRequested),
  tap((action) => debug(action)),
  withLatestFrom(this.store.pipe(select(selectAllFilters))),
  filter(([action, allFilters]) => isEmpty(allFilters)),
  mergeMap(() =>
    this.simService.getAllFilters().pipe(
      catchError(() => {
        return of({})
      })
    )
  ),
  map((allFilters) => new AllFiltersLoadedAction(allFilters))
)

如果存储已被填充（因为来自 API 的数据没有改变），我会使用filter它来防止发出 HTTP 请求（请参阅参考资料）mergeMap

但是，我总是想执行：

map((allFilters) => new AllFiltersLoadedAction(allFilters))

无论是否发出 HTTP 请求。但是，它不能在之前执行，mergeMap因为mergeMap确保allFilters数据可用。

有没有 RxJSalways do this类型的运算符？如果没有，我应该如何重构这段代码来实现我想要的？

目前，唯一的解决方案是删除filter，但这会导致发出不必要的 HTTP 请求。

谢谢

标签： angularrxjsngrxrxjs6

解决方案

只是不要使用filter并使用条件包装 HTTP 调用if：

...
withLatestFrom(...)
mergeMap(([action, allFilters]) => {
  if (isEmpty(allFilters)) {
    return of(allFilters);
  }
  return this.simService.getAllFilters()...
})
map((allFilters) => new AllFiltersLoadedAction(allFilters))

我不知道你到底想做什么，但我希望你能明白这一点。

推荐阅读