SubscriptionMessageAdapter

StockSharp.Algo

Adaptador de contra-assinatura.

Herda de: MessageAdapterWrapper

Construtores

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

Inicializa uma nova instância do SubscriptionMessageAdapter.

innerAdapter
Adaptador de mensagens interior.
SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter, ISubscriptionManager manager)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter, manager)

Inicializa uma nova instância do SubscriptionMessageAdapter com um gerenciador personalizado.

innerAdapter
Adaptador de mensagens interior.
manager
Gerente de assinaturas.

Propriedades

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

Restaurar assinatura ao reconectar.

Métodos

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

Criar uma cópia de SubscriptionMessageAdapter.

Retorna: Entendido.

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

Processo InnerAdapter output message.

message
A mensagem.
cancellationToken
Inscrição de cancelamento.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Processo InnerAdapter output message.

message
A mensagem.
cancellationToken
Inscrição de cancelamento.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Enviar mensagem.

message
Message.
cancellationToken
CancellationToken