LatencyMessageAdapter

StockSharp.Algo.Latency

消息适配器,自动计算网络延迟.

继承自: MessageAdapterWrapper

构造函数

LatencyMessageAdapter
public LatencyMessageAdapter(IMessageAdapter innerAdapter, ILatencyManager latencyManager)
latencyMessageAdapter = LatencyMessageAdapter(innerAdapter, latencyManager)

消息适配器,自动计算网络延迟.

innerAdapter
适配器,将给它发信息.
latencyManager
命令注册延迟计算管理器.

方法

CloneAsync
public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)
result = latencyMessageAdapter.CloneAsync(cancellationToken)

Create a copy of LatencyMessageAdapter.

cancellationToken
CancellationToken

返回值: Copy.

OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = latencyMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

进程 & ###InnerAdapter+##输出消息.

message
腾讯.
cancellationToken
取消的代币。
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = latencyMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

发来消息

message
Message.
cancellationToken
CancellationToken