Interface QueuedIterator<T>

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

Type Parameters

  • T

Methods

[asyncIterator] getPending getProcessed getReceived stop

Methods

[asyncIterator]

  • [asyncIterator](): AsyncIterator<T, any, any>

  • Returns AsyncIterator<T, any, any>

getPending

  • getPending(): number

  • Returns number

getProcessed

  • getProcessed(): number

  • Returns number

getReceived

  • getReceived(): number

  • Returns number

stop

  • stop(err?): void

  • Parameters

    • Optionalerr: Error

    Returns void

Settings

Member Visibility

On This Page

Methods