SubscriptionOnlineManager
StockSharp.Algo
Online subscription processing implementation.
实现: ISubscriptionOnlineManager
构造函数
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.
属性
State : ISubscriptionOnlineManagerState
State storage.
方法
ProcessInMessageAsync(Message, CancellationToken) : ValueTask<ValueTuple<Message[], Message[]>>
Process a message going into the inner adapter.
- message
- Incoming message.
- cancellationToken
- Cancellation token.
返回值: Processing result.
ProcessOutMessageAsync(Message, CancellationToken) : ValueTask<ValueTuple<Message, Message[]>>
Process a message coming from the inner adapter.
- message
- Outgoing message.
- cancellationToken
- Cancellation token.
返回值: Processing result.