Interface QueuedIterator<T>

Type Parameters

T

Hierarchy

Dispatcher<T>
- QueuedIterator
  - ConsumerMessages

Index

Methods

[asyncIterator] getPending getProcessed getReceived push stop

Methods

[asyncIterator]

[asyncIterator](): AsyncIterator<T, any, undefined>
Returns AsyncIterator<T, any, undefined>
- Defined in cjs/nats-base-client/core.ts:904

getPending

getPending(): number
Returns number
- Defined in cjs/nats-base-client/core.ts:910

getProcessed

getProcessed(): number
Returns number
- Defined in cjs/nats-base-client/core.ts:908

getReceived

getReceived(): number
Returns number
- Defined in cjs/nats-base-client/core.ts:912

push

push(v: T): void
Parameters
- v: T
Returns void
Inherited from Dispatcher.push
- Defined in cjs/nats-base-client/core.ts:900

stop

stop(err?: Error): void
Parameters
- Optional err: Error
Returns void
- Defined in cjs/nats-base-client/core.ts:906

Generated using TypeDoc