Skip to content

MessageStream

Defined in: sdks/js/node-sdk/dist/index.d.ts:408

One pending item. Construction selects callback mode or next-request acknowledgement.

T

V

  • AsyncIterable<V>

new MessageStream<T, V>(reader, convert, options?): MessageStream<T, V>

Defined in: sdks/js/node-sdk/dist/index.d.ts:410

MessageReaderSource<T>

(message, cursor) => V | Promise<V | undefined> | undefined

StreamOptions<T, V>

MessageStream<T, V>

catchUpChanged: () => Promise<MessageCatchUp>

Defined in: sdks/js/node-sdk/dist/index.d.ts:419

Promise<MessageCatchUp>


catchUpSnapshot: () => MessageCatchUp | Promise<MessageCatchUp>

Defined in: sdks/js/node-sdk/dist/index.d.ts:418

MessageCatchUp | Promise<MessageCatchUp>


end: () => Promise<IteratorReturnResult<undefined>>

Defined in: sdks/js/node-sdk/dist/index.d.ts:415

Promise<IteratorReturnResult<undefined>>


next: () => Promise<IteratorResult<V, undefined>>

Defined in: sdks/js/node-sdk/dist/index.d.ts:413

Promise<IteratorResult<V, undefined>>


return: () => Promise<IteratorReturnResult<undefined>>

Defined in: sdks/js/node-sdk/dist/index.d.ts:414

Promise<IteratorReturnResult<undefined>>


updateFilter: (conversationType?, consentStates?) => void | Promise<void>

Defined in: sdks/js/node-sdk/dist/index.d.ts:417

ConversationType

ConsentState[]

void | Promise<void>


updateScope: (groupIds?) => void | Promise<void>

Defined in: sdks/js/node-sdk/dist/index.d.ts:416

string[]

void | Promise<void>

get deliveredCursor(): DeliveryCursor | undefined

Defined in: sdks/js/node-sdk/dist/index.d.ts:412

DeliveryCursor | undefined


get isDone(): boolean

Defined in: sdks/js/node-sdk/dist/index.d.ts:411

boolean

[asyncIterator](): this

Defined in: sdks/js/node-sdk/dist/index.d.ts:420

this

AsyncIterable.[asyncIterator]