Skip to content

MessageStream

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:34

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/browser-sdk/src/MessageStream.ts:48

MessageReaderSource<T>

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

StreamOptions<T, V> = {}

MessageStream<T, V>

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

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:207

Promise<IteratorReturnResult<undefined>>

get deliveredCursor(): DeliveryCursor | undefined

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:69

DeliveryCursor | undefined


get isDone(): boolean

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:66

boolean

[asyncIterator](): MessageStream<T, V>

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:215

MessageStream<T, V>

AsyncIterable.[asyncIterator]


catchUpChanged(): Promise<MessageCatchUp>

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:214

Promise<MessageCatchUp>


catchUpSnapshot(): MessageCatchUp | Promise<MessageCatchUp>

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:213

MessageCatchUp | Promise<MessageCatchUp>


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

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:77

Promise<IteratorResult<V, undefined>>


return(): Promise<IteratorReturnResult<undefined>>

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:196

Promise<IteratorReturnResult<undefined>>


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

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:209

ConversationType

ConsentState[]

void | Promise<void>


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

Defined in: sdks/js/browser-sdk/src/MessageStream.ts:208

string[]

void | Promise<void>