Class DataReadQueue<T>

Type Parameters

T

Implements

Stream<T>

Index

Constructors

Methods

close read write

Constructors

constructor

new DataReadQueue<T>(): DataReadQueue<T>
Type Parameters
- T
Returns DataReadQueue<T>

Methods

close

close(): void
Returns void
- Defined in packages/general/src/util/DataReadQueue.ts:48

read

read(timeoutMs?): Promise<T>
Parameters
- timeoutMs: number = 60_000
Returns Promise<T>
Implementation of Stream.read
- Defined in packages/general/src/util/DataReadQueue.ts:19

write

write(data): Promise<void>
Parameters
- data: T
Returns Promise<void>
Implementation of Stream.write
- Defined in packages/general/src/util/DataReadQueue.ts:37