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)

Initializes a new instance of the CandleBuilderManager.

logReceiver

Log receiver.

idGenerator

Transaction id generator.

adapter

Adapter wrapper used for loopback messages and inner adapter access.

sendFinishedCandlesImmediatelly

Send finished candles immediately.

buffer

Storage buffer.

cloneOutCandles

Indicates whether outgoing candles should be cloned before emitting.

candleBuilderProvider

Candle builders provider.

Buffer

public IStorageBuffer Buffer { get; set; }

value = candleBuilderManager.Buffer
candleBuilderManager.Buffer = value

Storage buffer.

SendFinishedCandlesImmediatelly

public bool SendFinishedCandlesImmediatelly { get; set; }

value = candleBuilderManager.SendFinishedCandlesImmediatelly
candleBuilderManager.SendFinishedCandlesImmediatelly = value

Send out finished candles when they received.

ProcessInMessageAsync

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

result = candleBuilderManager.ProcessInMessageAsync(message, cancellationToken)

Process a message going into the inner adapter.

message

Incoming message.

cancellationToken

Cancellation token.

Returns: Processing result.

ProcessOutMessageAsync

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

result = candleBuilderManager.ProcessOutMessageAsync(message, cancellationToken)

Process a message coming from the inner adapter.

message

Outgoing message.

cancellationToken

Cancellation token.

Returns: Processing result.