ChannelMessageAdapter

StockSharp.Messages

Адаптер сообщений, пересылает сообщения через транспортный канал IMessageChannel.

Конструкторы

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()

Создайте копию ChannelMessageAdapter.

Возвращает: Копия.

Dispose

public override void Dispose()

channelMessageAdapter.Dispose()

Удаляет элементы в пуле, реализующие IDisposable.

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)

Отправить сообщение.