SubscriptionMessageAdapter

StockSharp.Algo

Adaptador de contador de suscripción.

Hereda de: MessageAdapterWrapper

Constructores

SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter)

Inicia una nueva instancia de la SubscriptionMessageAdapter.

innerAdapter
Adaptador interno de mensajes.
SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter, ISubscriptionManager manager)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter, manager)

Inicia una nueva instancia de SubscriptionMessageAdapter@ con un gestor personalizado.

innerAdapter
Adaptador interno de mensajes.
manager
Gerente de suscripción.

Propiedades

IsRestoreSubscriptionOnErrorReconnect
public bool IsRestoreSubscriptionOnErrorReconnect { get; set; }
value = subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect
subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect = value

Restaurar la suscripción en la reconexión.

Métodos

Clone
public override IMessageAdapter Clone()
result = subscriptionMessageAdapter.Clone()

Crear una copia de SubscriptionMessageAdapter.

Devuelve: Copiado.

InnerAdapterNewOutMessageAsync
protected override ValueTask InnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.InnerAdapterNewOutMessageAsync(message, cancellationToken)

Proceso InnerAdapter@ mensaje de salida.

message
El mensaje.
cancellationToken
Cancelación token.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Proceso InnerAdapter@ mensaje de salida.

message
El mensaje.
cancellationToken
Cancelación token.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Envía mensaje.

message
Message.
cancellationToken
CancellationToken