Function createCustomEffect create < Request , Response , TError , TState > ( handler , concurrencyOperator ? , initialState ? ) : EffectRunner < Request , Response , TError , TState > Type Parameters Request Response TError extends Error = Error TState = Response Parameters handler : EffectSource < Request , Response > concurrencyOperator : { < T , O > ( project , concurrent ? ) : OperatorFunction < T , ObservedValueOf < O > > ; < T , O > ( project , resultSelector , concurrent ? ) : OperatorFunction < T , ObservedValueOf < O > > ; < T , R , O > ( project , resultSelector , concurrent ? ) : OperatorFunction < T , R > ; } = mergeMap < T , O > ( project , concurrent ? ) : OperatorFunction < T , ObservedValueOf < O > > Type Parameters T O extends ObservableInput < any > Parameters project : ( ( value , index ) => O ) ( value , index ) : O Returns O Optional concurrent : number Returns OperatorFunction < T , ObservedValueOf < O > > < T , O > ( project , resultSelector , concurrent ? ) : OperatorFunction < T , ObservedValueOf < O > > Type Parameters T O extends ObservableInput < any > Parameters project : ( ( value , index ) => O ) ( value , index ) : O Returns O resultSelector : undefined Optional concurrent : number Returns OperatorFunction < T , ObservedValueOf < O > > < T , R , O > ( project , resultSelector , concurrent ? ) : OperatorFunction < T , R > Type Parameters T R O extends ObservableInput < any > Parameters project : ( ( value , index ) => O ) ( value , index ) : O Returns O resultSelector : ( ( outerValue , innerValue , outerIndex , innerIndex ) => R ) ( outerValue , innerValue , outerIndex , innerIndex ) : R Parameters outerValue : T innerValue : ObservedValueOf < O > outerIndex : number innerIndex : number Returns R Optional concurrent : number Returns OperatorFunction < T , R > Optional initialState : TState
Creates an Effect - A higher-order wrapper around a Promise-or-Observable returning function. The effect is cancelable if it returns an Observable.
createCustomEffectruns in the concurrency mode of the RxJS operator it is passed as its 2nd argument