Interface ProtobufMessageStream<T, S>

A message reader/writer that only uses one type of message

interface ProtobufMessageStream<T, S extends MessageStream = MessageStream> {
    read(options?: AbortOptions): Promise<T>;
    unwrap(): ProtobufStream<S>;
    write(d: T, options?: AbortOptions): Promise<void>;
    writeV(d: T[], options?: AbortOptions): Promise<void>;
}

Type Parameters

T
S extends MessageStream = MessageStream

Index

Methods

read unwrap write writeV

Methods

read

read(options?: AbortOptions): Promise<T>
Read a message from the stream
Parameters
- Optionaloptions: AbortOptions
Returns Promise<T>
- Defined in packages/utils/src/stream-utils.ts:428

unwrap

unwrap(): ProtobufStream<S>
Unwrap the underlying protobuf stream

Returns ProtobufStream<S>
- Defined in packages/utils/src/stream-utils.ts:443

write

write(d: T, options?: AbortOptions): Promise<void>
Write a message to the stream
Parameters
- d: T
- Optionaloptions: AbortOptions
Returns Promise<void>
- Defined in packages/utils/src/stream-utils.ts:433

writeV

writeV(d: T[], options?: AbortOptions): Promise<void>
Write several messages to the stream
Parameters
- d: T[]
- Optionaloptions: AbortOptions
Returns Promise<void>
- Defined in packages/utils/src/stream-utils.ts:438