Function chainParP_

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

  • A semi-push stream.

    It eagerly loads items until the concurrency target is met.

    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>

    • concurrency: number = Infinity

    Returns Source<B, E | E1>

Settings

Member Visibility

Theme

Generated using TypeDoc