Interface ConsumerMessages

Hierarchy

QueuedIterator<JsMsg>
Close
- ConsumerMessages

Index

Methods

[asyncIterator] close closed getPending getProcessed getReceived push status stop

Methods

[asyncIterator]

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

close

close(): Promise<void | Error>
Returns Promise<void | Error>
Inherited from Close.close
- Defined in cjs/jetstream/consumer.ts:274

closed

closed(): Promise<void | Error>
Returns Promise<void | Error>
Inherited from Close.closed
- Defined in cjs/jetstream/consumer.ts:275

getPending

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

getProcessed

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

getReceived

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

push

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

status

status(): Promise<AsyncIterable<ConsumerStatus>>
Returns Promise<AsyncIterable<ConsumerStatus>>
- Defined in cjs/jetstream/consumer.ts:279

stop

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

Generated using TypeDoc