SubscriptionOnlineMessageAdapter
StockSharp.Algo
在线订阅柜台适配器.
构造函数
SubscriptionOnlineMessageAdapter
public SubscriptionOnlineMessageAdapter(IMessageAdapter innerAdapter)
subscriptionOnlineMessageAdapter = SubscriptionOnlineMessageAdapter(innerAdapter)
初始化了 & ##SubscriptionOnlineMessageAdapter+#的新实例.
- innerAdapter
- 内相信息适配器.
SubscriptionOnlineMessageAdapter
public SubscriptionOnlineMessageAdapter(IMessageAdapter innerAdapter, ISubscriptionOnlineManager manager)
subscriptionOnlineMessageAdapter = SubscriptionOnlineMessageAdapter(innerAdapter, manager)
初始化 SubscriptionOnlineMessageAdapter 的新实例, 并设置自定义管理器 。
- innerAdapter
- 内相信息适配器.
- manager
- 在线订阅管理器.
方法
CloneAsync
public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)
result = subscriptionOnlineMessageAdapter.CloneAsync(cancellationToken)
Create a copy of SubscriptionOnlineMessageAdapter.
- cancellationToken
- CancellationToken
返回值: Copy.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionOnlineMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)
进程 & ###InnerAdapter+##输出消息.
- message
- 腾讯.
- cancellationToken
- 取消的代币。
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionOnlineMessageAdapter.OnSendInMessageAsync(message, cancellationToken)
发来消息
- message
- Message.
- cancellationToken
- CancellationToken