Class AsyncMessageQueue<T>

Single-consumer asynchronous queue used by protocol connection pull surfaces.

Type Parameters

T

Index

Constructors

Methods

close next push reopen

Constructors

constructor

new AsyncMessageQueue<T>(
highWaterMark?: number,
onHighWater?: (size: number) => void,
): AsyncMessageQueue<T>
Type Parameters
- T
Parameters
- highWaterMark: number = 1000
- OptionalonHighWater: (size: number) => void
Returns AsyncMessageQueue<T>
- Defined in sdk/src/shared/async-message-queue.ts:8

Methods

close

close(clear?: boolean): void
Parameters
- clear: boolean = true
Returns void
- Defined in sdk/src/shared/async-message-queue.ts:32

next

next(): Promise<T | null>
Returns Promise<T | null>
- Defined in sdk/src/shared/async-message-queue.ts:25

push

push(value: T): void
Parameters
- value: T
Returns void
- Defined in sdk/src/shared/async-message-queue.ts:13

reopen

reopen(): void
Returns void
- Defined in sdk/src/shared/async-message-queue.ts:39