SubscriptionOnlineManager
StockSharp.Algo
Online subscription processing implementation.
Implements: ISubscriptionOnlineManager
Constructors
SubscriptionOnlineManager(ILogReceiver, Func<DataType, bool>, ISubscriptionOnlineManagerState)
Online subscription processing implementation.
- logReceiver
- Log receiver.
- isSecurityRequired
- Check if a security id is required for the specified data type.
- state
- State storage.
Properties
State : ISubscriptionOnlineManagerState
State storage.
Methods
ProcessInMessageAsync(Message, CancellationToken) : ValueTask<ValueTuple<Message[], Message[]>>
Process a message going into the inner adapter.
- message
- Incoming message.
- cancellationToken
- Cancellation token.
Returns: Processing result.
ProcessOutMessageAsync(Message, CancellationToken) : ValueTask<ValueTuple<Message, Message[]>>
Process a message coming from the inner adapter.
- message
- Outgoing message.
- cancellationToken
- Cancellation token.
Returns: Processing result.