SubscriptionOnlineManager
StockSharp.Algo
在线订阅处理实施.
实现: ISubscriptionOnlineManager
构造函数
SubscriptionOnlineManager
public SubscriptionOnlineManager(ILogReceiver logReceiver, Func<DataType, bool> isSecurityRequired, ISubscriptionOnlineManagerState state)subscriptionOnlineManager = SubscriptionOnlineManager(logReceiver, isSecurityRequired, state)在线订阅处理实施.
- logReceiver
- 记录接收器。
- isSecurityRequired
- 检查是否需要金融工具 ID 用于指定的数据类型 。
- state
- 州库.
属性
State
public ISubscriptionOnlineManagerState State { get; }value = subscriptionOnlineManager.State州库.
方法
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessInMessageAsync(message, cancellationToken)处理一个消息进入内置适配器。
- message
- 来电消息.
- cancellationToken
- 取消的代币。
返回值: 处理结果。
ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessOutMessageAsync(message, cancellationToken)处理来自内置适配器的邮件 。
- message
- 传出消息.
- cancellationToken
- 取消的代币。
返回值: 处理结果。