CandleBuilderManager

StockSharp.Algo.Candles.Compression

Реализация обработки свечного конструктора.

Конструкторы

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: Генератор идентификаторов транзакций.
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: Токен отмены.

Возвращает: Результат обработки.