mogami-stream - v0.2.0
    Preparing search index...

    Interface PushOptions

    Queue limits for push sources, applied independently to each execution.

    interface PushOptions {
        capacity: number;
        onDrop?: (info: PushDropInfo) => undefined;
        overflow?: "error" | "drop-oldest" | "drop-newest";
    }
    Index
    capacity: number

    Maximum buffered values; must be a positive safe integer.

    onDrop?: (info: PushDropInfo) => undefined

    Synchronous overflow notification called after updating the queue. Receives one live statistics object per execution; reentrant drops update its count without re-entering onDrop. Synchronous throws fail the execution (or are recorded in suppressedErrors after cancellation or failure). Return values, including promises, are ignored and not awaited.

    overflow?: "error" | "drop-oldest" | "drop-newest"

    Full-queue policy. Defaults to error; event producers cannot be blocked.