- chainPar<E1, A, B>(fab: ((a: A) => Source<B, E1>), concurrency?: number, bufferSize?: number): (<E>(self: Source<A, E>) => Source<B, E1 | E>)
-
Parameters
-
fab: ((a: A) => Source<B, E1>)
-
Optional
concurrency: number
-
Optional
bufferSize: number
Returns (<E>(self: Source<A, E>) => Source<B, E1 | E>)