CandleBuilderManager
StockSharp.Algo.Candles.Compression
Implementação de processamento de velas.
Implementa: ICandleBuilderManager
Construtores
CandleBuilderManager
public CandleBuilderManager(ILogReceiver logReceiver, IdGenerator idGenerator, IMessageAdapterWrapper adapter, bool sendFinishedCandlesImmediatelly, IStorageBuffer buffer, bool cloneOutCandles, CandleBuilderProvider candleBuilderProvider)
candleBuilderManager = CandleBuilderManager(logReceiver, idGenerator, adapter, sendFinishedCandlesImmediatelly, buffer, cloneOutCandles, candleBuilderProvider)
Inicializa uma nova instância do CandleBuilderManager.
- logReceiver
- Receptor de registo.
- idGenerator
- Gerador de identificação de transação.
- adapter
- Embalagem adaptadora usada para mensagens loopback e acesso ao adaptador interno.
- sendFinishedCandlesImmediatelly
- Envie velas acabadas imediatamente.
- buffer
- Tampão de armazenamento.
- cloneOutCandles
- Indica se velas de saída devem ser clonadas antes de emitir.
- candleBuilderProvider
- Fornecedor de velas.
Propriedades
Buffer
public IStorageBuffer Buffer { get; set; }
value = candleBuilderManager.Buffer
candleBuilderManager.Buffer = value
Tampão de armazenamento.
SendFinishedCandlesImmediatelly
public bool SendFinishedCandlesImmediatelly { get; set; }
value = candleBuilderManager.SendFinishedCandlesImmediatelly
candleBuilderManager.SendFinishedCandlesImmediatelly = value
Envie velas acabadas quando receberem.
Métodos
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)
result = candleBuilderManager.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 = candleBuilderManager.ProcessOutMessageAsync(message, cancellationToken)
Processe uma mensagem vinda do adaptador interno.
- message
- Mensagem de saída.
- cancellationToken
- Inscrição de cancelamento.
Retorna: Resultado do processamento.