Flattens an Observable-of-Observables by applying combineLatest when the Observable-of-Observables completes.

combineLatestAll<R>(project?: (...values: any[]) => R)

Parameters

project

(...values: any[]) => R

Optional. Default is undefined. optional function to map the most recent values from each inner Observable into a new result. Takes each of the most recent values from each collected inner Observable as arguments, in order.

Description

combineLatestAll takes an Observable of Observables, and collects all Observables from it. Once the outer Observable completes, it subscribes to all collected Observables and combines their values using the combineLatest strategy, such that:

• Every time an inner Observable emits, the output Observable emits
• When the returned observable emits, it emits all of the latest values by:
  • If a project function is provided, it is called with each recent value from each inner Observable in whatever order they arrived, and the result of the project function is what is emitted by the output Observable.
  • If there is no project function, an array of all the most recent values is emitted by the output Observable.

Example

Map two click events to a finite interval Observable, then apply combineLatestAll

import { fromEvent, map, interval, take, combineLatestAll } from 'rxjs';

const clicks = fromEvent(document, 'click');
const higherOrder = clicks.pipe(
  map(() => interval(Math.random() * 2000).pipe(take(3))),
  take(2)
);
const result = higherOrder.pipe(combineLatestAll());

result.subscribe(x => console.log(x));

Overloads

combineLatestAll(): OperatorFunction<ObservableInput<T>, T[]>

Parameters

There are no parameters.

Returns

OperatorFunction<ObservableInput<T>, T[]>

combineLatestAll(): OperatorFunction<any, T[]>

Parameters

There are no parameters.

Returns

OperatorFunction<any, T[]>

combineLatestAll(project: (...values: T[]) => R): OperatorFunction<ObservableInput<T>, R>

Parameters

project

(...values: T[]) => R

Returns

OperatorFunction<ObservableInput<T>, R>

combineLatestAll(project: (...values: any[]) => R): OperatorFunction<any, R>

Parameters

project

(...values: any[]) => R

Returns

OperatorFunction<any, R>

See Also

• combineLatest
• combineLatestWith
• mergeAll