Interface ArrayOptions

Use ReadableOperatorOptions instead.

interface ArrayOptions {
    concurrency?: number;
    highWaterMark?: number;
    signal?: AbortSignal;
}

Properties

concurrency?: number

The maximum concurrent invocations of fn to call on the stream at once.

highWaterMark?: number

How many items to buffer while waiting for user consumption of the output.

concurrency * 2 - 1

signal?: AbortSignal