Skip to main content
Using Deno in production at your company? Earn free Deno merch.
Give us feedback
Module

x/natsws/src/nats-base-client.ts>QueuedIteratorImpl

WebSocket NATS
nats-io/nats.ws
Latest
class QueuedIteratorImpl
implements QueuedIterator<T>
import { QueuedIteratorImpl } from "https://deno.land/x/natsws@v1.28.0/src/nats-base-client.ts";

Constructors

new
QueuedIteratorImpl()

Properties

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

Methods

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