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.