QueuedIteratorImpl
import { QueuedIteratorImpl } from "https://raw.githubusercontent.com/nats-io/nats.deno/v1.27.0/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]();
§Implements
§Properties
§
dispatchedFn: DispatchedFn<T>
[src]§
ingestionFilterFn: IngestionFilterFn<T>
[src]§
protocolFilterFn: ProtocolFilterFn<T>
[src]