CandleBuilderManager

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)

Inicia una nueva instancia de la CandleBuilderManager.

logReceiver

Receptor de registro.

idGenerator

Generador de identificación de transacciones.

adapter

Envoltorio adaptador utilizado para mensajes de retroceso y acceso interior del adaptador.

sendFinishedCandlesImmediatelly

Envía velas terminadas inmediatamente.

buffer

Buffer de almacenamiento.

cloneOutCandles

Indica si las velas salientes deben ser clonadas antes de emitir.

candleBuilderProvider

Proveedor de constructores de velas.

Buffer

public IStorageBuffer Buffer { get; set; }

value = candleBuilderManager.Buffer
candleBuilderManager.Buffer = value

Buffer de almacenamiento.

SendFinishedCandlesImmediatelly

public bool SendFinishedCandlesImmediatelly { get; set; }

value = candleBuilderManager.SendFinishedCandlesImmediatelly
candleBuilderManager.SendFinishedCandlesImmediatelly = value

Envía velas terminadas cuando recibieron.

ProcessInMessageAsync

public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)

result = candleBuilderManager.ProcessInMessageAsync(message, cancellationToken)

Procesar un mensaje entrando en el adaptador interno.

message

Mensaje entrante.

cancellationToken

Cancelación token.

Devuelve: Resultado de procesamiento.

ProcessOutMessageAsync

public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)

result = candleBuilderManager.ProcessOutMessageAsync(message, cancellationToken)

Procesar un mensaje que viene del adaptador interno.

message

Mensaje saliente.

cancellationToken

Cancelación token.

Devuelve: Resultado de procesamiento.