LookupTrackingMessageAdapter
StockSharp.Algo
消息适配器,可以跟踪多个查询请求,并把它们放入单行队.
构造函数
LookupTrackingMessageAdapter
public LookupTrackingMessageAdapter(IMessageAdapter innerAdapter, ILookupTrackingManagerState state)
lookupTrackingMessageAdapter = LookupTrackingMessageAdapter(innerAdapter, state)
消息适配器,可以跟踪多个查询请求,并把它们放入单行队.
- innerAdapter
- 内相信息适配器.
- state
- 州库.
属性
TimeOut
private TimeSpan TimeOut { get; set; }
value = lookupTrackingMessageAdapter.TimeOut
lookupTrackingMessageAdapter.TimeOut = value
金融工具和投资组合的查询超时。
方法
CloneAsync
public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)
result = lookupTrackingMessageAdapter.CloneAsync(cancellationToken)
Create a copy of LookupTrackingMessageAdapter.
- cancellationToken
- CancellationToken
返回值: Copy.
Dispose
public override void Dispose()
lookupTrackingMessageAdapter.Dispose()
Disposes of items in the pool that implement IDisposable.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = lookupTrackingMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)
进程 & ###InnerAdapter+##输出消息.
- message
- 腾讯.
- cancellationToken
- 取消的代币。
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = lookupTrackingMessageAdapter.OnSendInMessageAsync(message, cancellationToken)
发来消息
- message
- Message.
- cancellationToken
- CancellationToken