Options
All
  • Public
  • Public/Protected
  • All
Menu

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

Properties

messagesToSend: Uint8Array[] = []
onClose: Event<ChannelCloseEvent> = ...
onError: Event<unknown> = ...
onMessageEmitter: Emitter<MessageProvider> = ...
underlyingChannel: Channel

Accessors

  • get onMessage(): Event<MessageProvider>

Methods

  • close(): void
  • commitSingleMessage(msg: Uint8Array): void
  • getWriteBuffer(): WriteBuffer
  • handleMessages(buffer: ReadBuffer): void
  • sendAccumulated(): void