Interface Consumer

Hierarchy

ExportedConsumer
- Consumer

Index

Methods

consume delete fetch info next

Methods

consume

consume(opts?: ConsumeOptions): Promise<ConsumerMessages>
Parameters
- Optional opts: ConsumeOptions
Returns Promise<ConsumerMessages>
Inherited from ExportedConsumer.consume
- Defined in cjs/jetstream/consumer.ts:263

delete

delete(): Promise<boolean>
Returns Promise<boolean>
- Defined in cjs/jetstream/consumer.ts:270

fetch

fetch(opts?: FetchOptions): Promise<ConsumerMessages>
Parameters
- Optional opts: FetchOptions
Returns Promise<ConsumerMessages>
Inherited from ExportedConsumer.fetch
- Defined in cjs/jetstream/consumer.ts:259

info

info(cached?: boolean): Promise<ConsumerInfo>
Parameters
- Optional cached: boolean
Returns Promise<ConsumerInfo>
- Defined in cjs/jetstream/consumer.ts:269

next

next(opts?: NextOptions): Promise<JsMsg>
Parameters
- Optional opts: NextOptions
Returns Promise<JsMsg>
Inherited from ExportedConsumer.next
- Defined in cjs/jetstream/consumer.ts:255

Generated using TypeDoc