CandleBuilderMessageAdapter
StockSharp.Algo.Candles.Compression
Candle builder adapter.
构造函数
CandleBuilderMessageAdapter(IMessageAdapter, CandleBuilderProvider, bool)
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(IMessageAdapter, CandleBuilderProvider, ICandleBuilderManager, bool)
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 : IStorageBuffer
Storage buffer.
SendFinishedCandlesImmediatelly : bool
Send out finished candles when they received.
方法
OnInnerAdapterNewOutMessageAsync(Message, CancellationToken) : ValueTask
Process InnerAdapter output message.
- message
- The message.
- cancellationToken
- Cancellation token.
OnSendInMessageAsync(Message, CancellationToken) : ValueTask
Send message.