stream.default.ReadableOperatorOptions

interface ReadableOperatorOptions

• 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.

• signal?: AbortSignal