Interface QueuedIterator<T>

interface QueuedIterator<T> {
    "[asyncIterator]"(): AsyncIterator<T>;
    getPending(): number;
    getProcessed(): number;
    getReceived(): number;
    stop(err?: Error): void;
}

Type Parameters

  • T

Methods

[asyncIterator] getPending getProcessed getReceived stop

Methods

[asyncIterator]

  • "[asyncIterator]"(): AsyncIterator<T>

    Returns AsyncIterator<T>

getPending

  • getPending(): number

    Returns number

getProcessed

  • getProcessed(): number

    Returns number

getReceived

  • getReceived(): number

    Returns number

stop

  • stop(err?: Error): void

    Parameters

    • Optionalerr: Error

    Returns void

Settings

Member Visibility

On This Page

Methods