ChannelMessageAdapter

StockSharp.Messages

Adaptador de mensajes, mensajes de avance a través de un canal de transporte IMessageChannel.

Constructores

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

channelMessageAdapter = ChannelMessageAdapter(innerAdapter, inputChannel, outputChannel)

Inicia una nueva instancia de la ChannelMessageAdapter.

InputChannel

public IMessageChannel InputChannel { get; }

value = channelMessageAdapter.InputChannel

Adaptador.

OutputChannel

public IMessageChannel OutputChannel { get; }

value = channelMessageAdapter.OutputChannel

Adaptador.

public bool OwnInputChannel { get; set; }

value = channelMessageAdapter.OwnInputChannel
channelMessageAdapter.OwnInputChannel = value

Controla la vida del canal de mensajes entrantes.

public bool OwnOutputChannel { get; set; }

value = channelMessageAdapter.OwnOutputChannel
channelMessageAdapter.OwnOutputChannel = value

Controla la vida del canal de mensajes salientes.

Clone

public override IMessageAdapter Clone()

result = channelMessageAdapter.Clone()

Crear una copia de ChannelMessageAdapter.

Devuelve: Copiado.

Dispose

public override void Dispose()

channelMessageAdapter.Dispose()

Desembolsos de elementos en la piscina que implementan IDesechable.

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Proceso InnerAdapter@ mensaje de salida.

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = channelMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Envía mensaje.