Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ChannelMultiplexer

The write buffers in this implementation immediately write to the underlying channel, so we rely on writers to the multiplexed channels to always commit their messages and always in one go.

Hierarchy

  • ChannelMultiplexer

Implements

Index

Constructors

Properties

onOpenChannelEmitter: Emitter<{ channel: Channel; id: string }> = ...
openChannels: Map<string, ForwardingChannel> = ...
pendingOpen: Map<string, ((channel: ForwardingChannel) => void)> = ...
toDispose: DisposableCollection = ...
underlyingChannel: Channel

Accessors

  • get onDidOpenChannel(): Event<{ channel: Channel; id: string }>

Methods

  • closeChannel(id: string): void
  • dispose(): void
  • getOpenChannel(id: string): undefined | Channel
  • handleAckOpen(id: string): void
  • handleClose(id: string): void
  • handleError(error: unknown): void
  • handleOpen(id: string): void