CandleBuilderManager
StockSharp.Algo.Candles.Compression
Candle builder processing implementation.
コンストラクター
CandleBuilderManager(ILogReceiver, IdGenerator, IMessageAdapterWrapper, bool, IStorageBuffer, bool, 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 : IStorageBuffer
Storage buffer.
SendFinishedCandlesImmediatelly : bool
Send out finished candles when they received.
メソッド
ProcessInMessageAsync(Message, CancellationToken) : ValueTask<ValueTuple<Message[], Message[]>>
Process a message going into the inner adapter.
- message
- Incoming message.
- cancellationToken
- Cancellation token.
戻り値: Processing result.
ProcessOutMessageAsync(Message, CancellationToken) : ValueTask<ValueTuple<Message, Message[]>>
Process a message coming from the inner adapter.
- message
- Outgoing message.
- cancellationToken
- Cancellation token.
戻り値: Processing result.