CandleBuilderManager
StockSharp.Algo.Candles.Compression
烛台建设处理实施.
构造函数
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)初始化了 & ##CandleBuilderManager+#的新实例.
- logReceiver
- 记录接收器。
- idGenerator
- 交易ID生成器。
- adapter
- 用于回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回回
- sendFinishedCandlesImmediatelly
- 立即发送完成的蜡烛。
- buffer
- 存储缓冲器.
- cloneOutCandles
- 说明是否应当在排放前复制出蜡烛。
- candleBuilderProvider
- 烛所建站供养.
属性
Buffer
public IStorageBuffer Buffer { get; set; }value = candleBuilderManager.Buffer
candleBuilderManager.Buffer = value存储缓冲器.
SendFinishedCandlesImmediatelly
public bool SendFinishedCandlesImmediatelly { get; set; }value = candleBuilderManager.SendFinishedCandlesImmediatelly
candleBuilderManager.SendFinishedCandlesImmediatelly = value接到蜡烛就把蜡烛送出去
方法
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)result = candleBuilderManager.ProcessInMessageAsync(message, cancellationToken)处理一个消息进入内置适配器。
- message
- 来电消息.
- cancellationToken
- 取消的代币。
返回值: 处理结果。
ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)result = candleBuilderManager.ProcessOutMessageAsync(message, cancellationToken)处理来自内置适配器的邮件 。
- message
- 传出消息.
- cancellationToken
- 取消的代币。
返回值: 处理结果。