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.

Implements

Disposable

Index

Constructors

constructor

new ChannelMultiplexer(underlyingChannel): ChannelMultiplexer
Parameters
- underlyingChannel: Channel
Returns ChannelMultiplexer
- Defined in packages/core/src/common/message-rpc/channel.ts:165

Properties

`Protected` `Readonly` onOpenChannelEmitter

onOpenChannelEmitter: Emitter<{
channel: Channel;
id: string;
}> = ...

Type declaration

channel: Channel
id: string

`Protected` openChannels

openChannels: Map<string, ForwardingChannel> = ...

`Protected` pendingOpen

pendingOpen: Map<string, ((channel) => void)> = ...

Type declaration

- (channel): void
- Parameters
  - channel: ForwardingChannel
  Returns void

`Protected` toDispose

toDispose: DisposableCollection = ...

`Protected` `Readonly` underlyingChannel

underlyingChannel: Channel

Accessors

onDidOpenChannel

get onDidOpenChannel(): Event<{
channel: Channel;
id: string;
}>
Returns Event<{
channel: Channel;
id: string;
}>
- Defined in packages/core/src/common/message-rpc/channel.ts:159

Methods

`Protected` closeChannel

closeChannel(id): void
Parameters
- id: string
Returns void
- Defined in packages/core/src/common/message-rpc/channel.ts:272

`Protected` createChannel

createChannel(id): ForwardingChannel
Parameters
- id: string
Returns ForwardingChannel
- Defined in packages/core/src/common/message-rpc/channel.ts:259

dispose

dispose(): void
Dispose this object.

Returns void
Implementation of Disposable.dispose
- Defined in packages/core/src/common/message-rpc/channel.ts:296

getOpenChannel

getOpenChannel(id): undefined | Channel
Parameters
- id: string
Returns undefined | Channel
- Defined in packages/core/src/common/message-rpc/channel.ts:292

`Protected` handleAckOpen

handleAckOpen(id): void
Parameters
- id: string
Returns void
- Defined in packages/core/src/common/message-rpc/channel.ts:214

`Protected` handleClose

handleClose(id): void
Parameters
- id: string
Returns void
- Defined in packages/core/src/common/message-rpc/channel.ts:244

`Protected` handleData

handleData(id, data): void
Parameters
- id: string
- data: ReadBuffer
Returns void
- Defined in packages/core/src/common/message-rpc/channel.ts:252

`Protected` handleError

handleError(error): void
Parameters
- error: unknown
Returns void
- Defined in packages/core/src/common/message-rpc/channel.ts:174

`Protected` handleMessage

handleMessage(buffer): void
Parameters
- buffer: ReadBuffer
Returns void
- Defined in packages/core/src/common/message-rpc/channel.ts:195

`Protected` handleOpen

handleOpen(id): void
Parameters
- id: string
Returns void
- Defined in packages/core/src/common/message-rpc/channel.ts:228

onUnderlyingChannelClose

onUnderlyingChannelClose(event?): void
Parameters
- Optional event: ChannelCloseEvent
Returns void
- Defined in packages/core/src/common/message-rpc/channel.ts:180

open

open(id): Promise<Channel>
Parameters
- id: string
Returns Promise<Channel>
- Defined in packages/core/src/common/message-rpc/channel.ts:281

`Protected` prepareWriteBuffer

prepareWriteBuffer(id): WriteBuffer
Parameters
- id: string
Returns WriteBuffer
- Defined in packages/core/src/common/message-rpc/channel.ts:265