ISubscriptionOnlineManager
StockSharp.Algo
Online subscription processing logic.
Methods
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)result = iSubscriptionOnlineManager.ProcessInMessageAsync(message, cancellationToken)Process a message going into the inner adapter.
- message
- Incoming message.
- cancellationToken
- Cancellation token.
Returns: Processing result.
ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)result = iSubscriptionOnlineManager.ProcessOutMessageAsync(message, cancellationToken)Process a message coming from the inner adapter.
- message
- Outgoing message.
- cancellationToken
- Cancellation token.
Returns: Processing result.