SubscriptionOnlineManager

StockSharp.Algo

Aplicação de processamento de assinatura online.

Implementa: ISubscriptionOnlineManager

Construtores

SubscriptionOnlineManager
public SubscriptionOnlineManager(ILogReceiver logReceiver, Func<DataType, bool> isSecurityRequired, ISubscriptionOnlineManagerState state)
subscriptionOnlineManager = SubscriptionOnlineManager(logReceiver, isSecurityRequired, state)

Aplicação de processamento de assinatura online.

logReceiver
Receptor de registo.
isSecurityRequired
Verificar se é necessário um ID de instrumento financeiro para o tipo de dados especificado.
state
Armazém estatal.

Propriedades

State
public ISubscriptionOnlineManagerState State { get; }
value = subscriptionOnlineManager.State

Armazém estatal.

Métodos

ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionOnlineManager.ProcessInMessageAsync(message, cancellationToken)

Processe uma mensagem entrando no adaptador interno.

message
Mensagem a chegar.
cancellationToken
Inscrição de cancelamento.

Retorna: Resultado do processamento.

ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionOnlineManager.ProcessOutMessageAsync(message, cancellationToken)

Processe uma mensagem vinda do adaptador interno.

message
Mensagem de saída.
cancellationToken
Inscrição de cancelamento.

Retorna: Resultado do processamento.