Documentation / @eventkit/base / concatAll

Function: concatAll()

function concatAll<O>(): OperatorFunction<O, ObservedValueOf<O>>

Converts an observable that yields observables (called a higher-order observable) into a first-order observable which delivers all the values from the inner observables in order. It only subscribes to an inner observable only after the previous inner observable has completed. All values emitted by the inner observables are emitted in order.

Note: If the source observable emits observables quickly and endlessly, and the inner observables it emits generally complete slower than the source emits, you can run into memory issues as the incoming observables collect in an unbounded buffer.

Note: concatAll is equivalent to mergeAll with the concurrency parameter set to 1.

Type Parameters

Type Parameter
O extends AsyncObservableInput<any>

Returns

OperatorFunction<O, ObservedValueOf<O>>