rxjs - 逻辑或组合 2 个或多个可观察流

Question

我有 2 个 observables，它们都指示它们是否正在加载数据。它们来自@ngrx/data。

loadingA$: Observable<boolean>
loadingB$: Observable<boolean>

我想使用 rxjs 或更优雅的方法对两者进行“逻辑或”组合，以在其中任何一个为真时执行任何操作。也许是 ramdajs？，也许是组合加载状态？然而，不同的组件需要不同的加载流组合。

此外，如果我有 20 个流，它不应该仅限于 2 个流。

(!) 我不想分配额外的局部变量。

Answer 1

combineLatest(loadingA$, loadingB$).pipe(map((a, b) => a || b));

或

const anyLoading = (...observables: Observable<boolean>[]) => combineLatest(observables).pipe(
  map(bools => bools.some(loading => loading))
);

并使用它

anyLoading(loadingA$, loadingB$);

const { combineLatest, BehaviorSubject } = rxjs;
const { map } = rxjs.operators;

const anyLoading = (...observables) => combineLatest(observables).pipe(
  map(bools => bools.some(loading => loading))
);

const loadingA$ = new BehaviorSubject(false);
const loadingB$ = new BehaviorSubject(true);

anyLoading(loadingA$, loadingB$).subscribe(loading => { console.log(loading); });

loadingB$.next(false);

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.5.3/rxjs.umd.min.js"></script>