ChannelMessageAdapter — StockSharp 文档

构造函数

public ChannelMessageAdapter(IMessageAdapter innerAdapter, IMessageChannel inputChannel, IMessageChannel outputChannel)

channelMessageAdapter = ChannelMessageAdapter(innerAdapter, inputChannel, outputChannel)

初始化了 & ##ChannelMessageAdapter+#的新实例.

InputChannel

public IMessageChannel InputChannel { get; }

value = channelMessageAdapter.InputChannel

适从者.

OutputChannel

public IMessageChannel OutputChannel { get; }

value = channelMessageAdapter.OutputChannel

适从者.

public bool OwnInputChannel { get; set; }

value = channelMessageAdapter.OwnInputChannel
channelMessageAdapter.OwnInputChannel = value

控制来信通道的寿命。

public bool OwnOutputChannel { get; set; }

value = channelMessageAdapter.OwnOutputChannel
channelMessageAdapter.OwnOutputChannel = value

控制发送消息通道的寿命。

Clone

public override IMessageAdapter Clone()

result = channelMessageAdapter.Clone()

Create a copy of ChannelMessageAdapter.

返回值: 收到了,我们得去查查

Dispose

public override void Dispose()

channelMessageAdapter.Dispose()

执行可处理的池中项目的处置。

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

进程 & ###InnerAdapter+##输出消息.

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

发来消息