logical OR combine 2 or more observable streams

Question

I have 2 observables that both indicate if they're loading data or not. They come from @ngrx/data.

loadingA$: Observable
loadingB$: Observable

I'd like to "logical OR" combine the two to do whatever when either is true, using rxjs or more elegant method. Maybe ramdajs?, maybe a combined loading state? However different components need different combinations of loading streams.

Also, what if I have 20 streams, it shouldn't be limited to 2 streams only.

(!) I do not want to assign additional local variables.

user_1679126 · Answer

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

or

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

and use it

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);

logical OR combine 2 or more observable streams

1 Answers