IStorageProcessor

StockSharp.Algo.Storages

Интерфейс процессора хранилища.

Свойства

public CandleBuilderProvider CandleBuilderProvider { get; }

value = iStorageProcessor.CandleBuilderProvider

Поставщик производителей свечей.

Settings

public StorageCoreSettings Settings { get; }

value = iStorageProcessor.Settings

Настройки хранилища.

Методы

ProcessMarketData

public IAsyncEnumerable<Message> ProcessMarketData(MarketDataMessage message, CancellationToken cancellationToken)

result = iStorageProcessor.ProcessMarketData(message, cancellationToken)

Процесс MarketDataMessage.

message: Сообщение с рыночными данными (используется как подписка/отмена подписки в исходящем случае, событие подтверждения в входящем случае).
cancellationToken: Токен отмены.

Возвращает: Последовательность исходящих сообщений. Если подписку необходимо перенаправить на внутренний адаптер, результирующее сообщение MarketDataMessage возвращается как последнее сообщение в последовательности.

Reset

public void Reset()

iStorageProcessor.Reset()

Чтобы сбросить состояние.