Class BatchingChannel

Wraps and underlying channel to send/receive multiple messages in one go:

multiple messages to be sent from one stack get sent in bulk at process.nextTick.
each incoming message is handled in a separate process.nextTick.

Hierarchy

BatchingChannel

Implements

Channel

Index

Constructors

constructor

Properties

Accessors

onMessage

Methods

Constructors

constructor

new BatchingChannel(underlyingChannel: Channel): BatchingChannel

- Defined in packages/plugin-ext/src/common/rpc-protocol.ts:160
Parameters
- underlyingChannel: Channel
Returns BatchingChannel

Properties

Protected messagesToSend

messagesToSend: Uint8Array[] = []

Readonly onClose

onClose: Event<ChannelCloseEvent> = ...

Readonly onError

onError: Event<unknown> = ...

Protected onMessageEmitter

onMessageEmitter: Emitter<MessageProvider> = ...

Protected underlyingChannel

underlyingChannel: Channel

Accessors

onMessage

get onMessage(): Event<MessageProvider>

Implementation of Channel.onMessage
- Defined in packages/plugin-ext/src/common/rpc-protocol.ts:165
Returns Event<MessageProvider>

Methods

close

close(): void

Implementation of Channel.close
- Defined in packages/plugin-ext/src/common/rpc-protocol.ts:172
Returns void

Protected commitSingleMessage

commitSingleMessage(msg: Uint8Array): void

- Defined in packages/plugin-ext/src/common/rpc-protocol.ts:184
Parameters
- msg: Uint8Array
Returns void

getWriteBuffer

getWriteBuffer(): WriteBuffer

Implementation of Channel.getWriteBuffer
- Defined in packages/plugin-ext/src/common/rpc-protocol.ts:178
Returns WriteBuffer

Protected handleMessages

handleMessages(buffer: ReadBuffer): void

- Defined in packages/plugin-ext/src/common/rpc-protocol.ts:211
Parameters
- buffer: ReadBuffer
Returns void

Protected sendAccumulated

sendAccumulated(): void

- Defined in packages/plugin-ext/src/common/rpc-protocol.ts:196
Returns void