Type Alias BackpressureConfig<T>

Shared backpressure configuration — concurrency limit, buffer size, and overflow callback.

type BackpressureConfig<T> = {
    bufferSize?: number;
    maxConcurrency?: number;
    onBufferOverflow?: DataHandler<T>;
}

Type Parameters

T

Index

Properties

bufferSize? maxConcurrency? onBufferOverflow?

Properties

`Optional` `Readonly`bufferSize

bufferSize?: number

`Optional` `Readonly`maxConcurrency

maxConcurrency?: number

`Optional` `Readonly`onBufferOverflow

onBufferOverflow?: DataHandler<T>