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.