CandleBuilderMessageAdapter

CandleBuilderMessageAdapter

public CandleBuilderMessageAdapter(IMessageAdapter innerAdapter, CandleBuilderProvider candleBuilderProvider, bool cloneOutCandles)

candleBuilderMessageAdapter = CandleBuilderMessageAdapter(innerAdapter, candleBuilderProvider, cloneOutCandles)

Initializes a new instance of the CandleBuilderMessageAdapter.

innerAdapter

Inner message adapter.

candleBuilderProvider

Candle builders provider.

cloneOutCandles

Indicates whether outgoing candles should be cloned before emitting.

CandleBuilderMessageAdapter

public CandleBuilderMessageAdapter(IMessageAdapter innerAdapter, CandleBuilderProvider candleBuilderProvider, ICandleBuilderManager manager, bool cloneOutCandles)

candleBuilderMessageAdapter = CandleBuilderMessageAdapter(innerAdapter, candleBuilderProvider, manager, cloneOutCandles)

Initializes a new instance of the CandleBuilderMessageAdapter with a custom manager.

innerAdapter

Inner message adapter.

candleBuilderProvider

Candle builders provider.

manager

Candle builder manager.

cloneOutCandles

Indicates whether outgoing candles should be cloned before emitting.

Buffer

public IStorageBuffer Buffer { get; set; }

value = candleBuilderMessageAdapter.Buffer
candleBuilderMessageAdapter.Buffer = value

Storage buffer.

SendFinishedCandlesImmediatelly

public bool SendFinishedCandlesImmediatelly { get; set; }

value = candleBuilderMessageAdapter.SendFinishedCandlesImmediatelly
candleBuilderMessageAdapter.SendFinishedCandlesImmediatelly = value

Send out finished candles when they received.

Clone

public override IMessageAdapter Clone()

result = candleBuilderMessageAdapter.Clone()

Create a copy of CandleBuilderMessageAdapter.

Returns: Copy.

OnInnerAdapterNewOutMessageAsync

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = candleBuilderMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message

The message.

cancellationToken

Cancellation token.

OnSendInMessageAsync

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = candleBuilderMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Send message.

message

Message.

cancellationToken

CancellationToken