SubscriptionOnlineManager
StockSharp.Algo
Implementierung der Online-Abonnementverarbeitung.
Implementiert: ISubscriptionOnlineManager
Konstruktoren
SubscriptionOnlineManager
public SubscriptionOnlineManager(ILogReceiver logReceiver, Func<DataType, bool> isSecurityRequired, ISubscriptionOnlineManagerState state)subscriptionOnlineManager = SubscriptionOnlineManager(logReceiver, isSecurityRequired, state)Implementierung der Online-Abonnementverarbeitung.
- logReceiver
- Protokollempfänger.
- isSecurityRequired
- Prüfen Sie, ob für den angegebenen Datentyp eine Finanzinstrument-ID erforderlich ist.
- state
- staatliche Lagerung.
Eigenschaften
State
public ISubscriptionOnlineManagerState State { get; }value = subscriptionOnlineManager.Statestaatliche Lagerung.
Methoden
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessInMessageAsync(message, cancellationToken)Verarbeiten Sie eine Nachricht, die in den inneren Adapter gelangt.
- message
- Eingehende Nachricht.
- cancellationToken
- Löschungszeichen.
Rückgabe: Verarbeitungsergebnis.
ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessOutMessageAsync(message, cancellationToken)Verarbeiten Sie eine Nachricht, die vom inneren Adapter kommt.
- message
- Abgehende Nachricht.
- cancellationToken
- Löschungszeichen.
Rückgabe: Verarbeitungsergebnis.