Class AsyncMessageQueue<T>

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

With buffer set to false a pushed value is handed to a pending next() waiter or discarded; nothing is ever stored for a later drain.

Type Parameters

T

Index

Constructors

Methods

close next push reopen

Constructors

constructor

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

Methods

close

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

next

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

push

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

reopen

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