Skip to content

Documentation / @eventkit/base / mergeMap

Function: mergeMap() ​

ts
function mergeMap<T, O>(predicate, concurrency): OperatorFunction<T, ObservedValueOf<O>>

Applies a predicate function to each value yielded by the source observable, which returns a different observable that will be merged into the output observable using mergeAll.

Type Parameters ​

Type Parameter
T
O extends AsyncObservableInput<any>

Parameters ​

ParameterTypeDefault value
predicate(value, index) => Oundefined
concurrencynumberInfinity

Returns ​

OperatorFunction<T, ObservedValueOf<O>>

Released under the MIT License.