SecurityNativeIdManager
StockSharp.Algo
Security native id processing implementation.
Implementa: ISecurityNativeIdManager, IDisposable
Construtores
SecurityNativeIdManager(ILogReceiver, INativeIdStorageProvider, bool)
Initializes a new instance of the SecurityNativeIdManager.
- logReceiver
- Log receiver.
- storageProvider
- Security native identifier storage provider.
- isNativeIdentifiersPersistable
- Whether native identifiers are persistable.
Métodos
Dispose()
Disposes of items in the pool that implement IDisposable.
InitializeAsync(string, CancellationToken) : ValueTask
Initialize from storage provider.
- storageName
- Storage name.
- cancellationToken
- Cancellation token.
ProcessInMessageAsync(Message, CancellationToken) : ValueTask<ValueTuple<Message[], Message[]>>
Process a message going into the inner adapter.
- message
- Incoming message.
- cancellationToken
- Cancellation token.
Retorna: Processing result.
ProcessOutMessageAsync(Message, CancellationToken) : ValueTask<ValueTuple<Message, Message[], Message[]>>
Process a message coming from the inner adapter.
- message
- Outgoing message.
- cancellationToken
- Cancellation token.
Retorna: Processing result.
Eventos
ProcessSuspendedRequested : Func<SecurityId, CancellationToken, ValueTask>
Event raised when a new native id is added from storage and suspended messages need processing.