SecurityNativeIdManager

StockSharp.Algo

Внедрение встроенной обработки идентификаторов финансовых инструментов.

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

public SecurityNativeIdManager(ILogReceiver logReceiver, INativeIdStorageProvider storageProvider, bool isNativeIdentifiersPersistable)

securityNativeIdManager = SecurityNativeIdManager(logReceiver, storageProvider, isNativeIdentifiersPersistable)

Инициализирует новый экземпляр SecurityNativeIdManager.

logReceiver: Приемник журналов.
storageProvider: Поставщик хранилища собственных идентификаторов финансовых инструментов.
isNativeIdentifiersPersistable: Являются ли собственные идентификаторы постоянными.

Dispose

public void Dispose()

securityNativeIdManager.Dispose()

Удаляет элементы в пуле, реализующие IDisposable.

public ValueTask InitializeAsync(string storageName, CancellationToken cancellationToken)

result = securityNativeIdManager.InitializeAsync(storageName, cancellationToken)

Инициализируйте от поставщика хранилища.

public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)

result = securityNativeIdManager.ProcessInMessageAsync(message, cancellationToken)

Обработать сообщение, поступающее во внутренний адаптер.

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

public ValueTask<ValueTuple<Message, Message[], Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)

result = securityNativeIdManager.ProcessOutMessageAsync(message, cancellationToken)

Обработать сообщение, поступающее от внутреннего адаптера.

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

public event Func<SecurityId, CancellationToken, ValueTask> ProcessSuspendedRequested

securityNativeIdManager.ProcessSuspendedRequested += handler

Событие возникает, когда из хранилища добавляется новый собственный идентификатор и приостановленные сообщения требуют обработки.