QueuedIteratorImpl | /src/nats-base-client.ts | natsws@v1.29.2

Module

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

WebSocket NATS

nats-io/nats.ws

Latest

mod.ts (default module)

JetStreamAccountStats

JetStreamApiStats

JetStreamClient

JetStreamManager

JetStreamManagerOptions

JetStreamOptions

JetStreamPublishOptions

JetStreamUsageAccountLimits

Msg

Sub

SubjectTransformConfig

TypedSubscriptionOptions

UserPass

Views

AbortOnMissingResource

IngestionFilterFnResult

JetStreamPullSubscription

JetStreamSubscription

JetStreamSubscriptionOptions

ObjectStoreMetaOptions

ObjectStoreOptions

ObjectStorePutOpts

ObjectStoreStatus

OrderedConsumerOptions

StreamInfoRequestOptions

ServiceErrorCodeHeader

ServiceErrorHeader

backoff

buildAuthenticator

canonicalMIMEHeaderKey

usernamePasswordAuthenticator

Msg

Sub

TypedSubscriptionOptions

IngestionFilterFnResult

ServiceErrorCodeHeader

canonicalMIMEHeaderKey

checkOptions

checkUnsupportedOption

extractProtocolMessage

usernamePasswordAuthenticator

class QueuedIteratorImpl

implements QueuedIterator<T>

import { QueuedIteratorImpl } from "https://deno.land/x/natsws@v1.29.2/src/nats-base-client.ts";

Constructors

new

QueuedIteratorImpl()

Type Parameters

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]()