ISecurityNativeIdManager
StockSharp.Algo
Security native id processing logic.
Implementiert: IDisposable
Methoden
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.
Rückgabe: Processing result: toInner - messages to send to inner adapter, toOut - messages to raise as output.
ProcessOutMessageAsync(Message, CancellationToken) : ValueTask<ValueTuple<Message, Message[], Message[]>>
Process a message coming from the inner adapter.
- message
- Outgoing message.
- cancellationToken
- Cancellation token.
Rückgabe: Processing result: forward - message to forward to outer, extraOut - additional messages to forward, loopbackIn - messages to send back to inner adapter.
Ereignisse
ProcessSuspendedRequested : Func<SecurityId, CancellationToken, ValueTask>
Event raised when a new native id is added from storage and suspended messages need processing.