Function chainPar_

  • chainPar_<E, E1, A, B>(self: Source<A, E>, fab: ((a: A) => Source<B, E1>), concurrency?: number, bufferSize?: number): Source<B, E | E1>

  • Type Parameters

    • E

    • E1

    • A

    • B

    Parameters

    • self: Source<A, E>
    • fab: ((a: A) => Source<B, E1>)
        • (a: A): Source<B, E1>

        • Parameters

          • a: A

          Returns Source<B, E1>

    • Optional concurrency: number
    • bufferSize: number = Infinity

    Returns Source<B, E | E1>

Settings

Member Visibility

Theme

Generated using TypeDoc