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.