SubscriptionOnlineManager
StockSharp.Algo
Online subscription processing implementation.
Implements: ISubscriptionOnlineManager
Constructors
SubscriptionOnlineManager
public SubscriptionOnlineManager(ILogReceiver logReceiver, Func<DataType, bool> isSecurityRequired, ISubscriptionOnlineManagerState state)subscriptionOnlineManager = SubscriptionOnlineManager(logReceiver, isSecurityRequired, state)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
public ISubscriptionOnlineManagerState State { get; }value = subscriptionOnlineManager.StateState storage.
Methods
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.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 = subscriptionOnlineManager.ProcessOutMessageAsync(message, cancellationToken)Process a message coming from the inner adapter.
- message
- Outgoing message.
- cancellationToken
- Cancellation token.
Returns: Processing result.