Hi there! Are you looking for the official Deno documentation? Try docs.deno.com for all your Deno learning needs.

QueuedIteratorImpl

import { QueuedIteratorImpl } from "https://raw.githubusercontent.com/nats-io/nats.deno/v1.28.2/nats-base-client/internal_mod.ts";
class QueuedIteratorImpl<T> implements QueuedIterator<T> {
constructor();
_data?: unknown;
ctx?: unknown;
dispatchedFn?: DispatchedFn<T>;
done: boolean;
err?: Error;
filtered: number;
inflight: number;
ingestionFilterFn?: IngestionFilterFn<T>;
iterClosed: Deferred<void | Error>;
noIterator: boolean;
pendingFiltered: number;
processed: number;
protocolFilterFn?: ProtocolFilterFn<T>;
received: number;
signal: Deferred<void>;
time: number;
yielding: boolean;
yields: T[];
 
getPending(): number;
getProcessed(): number;
getReceived(): number;
async *iterate(): AsyncIterableIterator<T>;
push(v: T): void;
stop(err?: Error): void;
[Symbol.asyncIterator]();
}

§Type Parameters

§Implements

§Constructors

§
new QueuedIteratorImpl()
[src]

§Properties

§
_data: unknown
[src]
§
ctx: unknown
[src]
§
dispatchedFn: DispatchedFn<T>
[src]
§
done: boolean
[src]
§
err: Error
[src]
§
filtered: number
[src]
§
inflight: number
[src]
§
ingestionFilterFn: IngestionFilterFn<T>
[src]
§
iterClosed: Deferred<void | Error>
[src]
§
noIterator: boolean
[src]
§
pendingFiltered: number
[src]
§
processed: number
[src]
§
protocolFilterFn: ProtocolFilterFn<T>
[src]
§
received: number
[src]
§
signal: Deferred<void>
[src]
§
time: number
[src]
§
yielding: boolean
[src]
§
yields: T[]
[src]

§Methods

§
getPending(): number
[src]
§
getProcessed(): number
[src]
§
getReceived(): number
[src]
§
iterate(): AsyncIterableIterator<T>
[src]
§
push(v: T): void
[src]
§
stop(err?: Error): void
[src]
§
[Symbol.asyncIterator]()
[src]