HeartbeatMessageAdapter
StockSharp.Algo
控制连接的电文适配器 。
构造函数
HeartbeatMessageAdapter
public HeartbeatMessageAdapter(IMessageAdapter innerAdapter)heartbeatMessageAdapter = HeartbeatMessageAdapter(innerAdapter)初始化了 & ##HeartbeatMessageAdapter+#的新实例.
- innerAdapter
- 地底适应器.
HeartbeatMessageAdapter
public HeartbeatMessageAdapter(IMessageAdapter innerAdapter, IHeartbeatManagerState state)heartbeatMessageAdapter = HeartbeatMessageAdapter(innerAdapter, state)初始化了 & # #HeartbeatMessageAdapter # # 的新实例, 并带有明确的状态 。
- innerAdapter
- 地底适应器.
- state
- 州库.
属性
SuppressReconnectingErrors
public bool SuppressReconnectingErrors { get; set; }value = heartbeatMessageAdapter.SuppressReconnectingErrors
heartbeatMessageAdapter.SuppressReconnectingErrors = value禁止重联错误.
方法
Clone
public override IMessageAdapter Clone()result = heartbeatMessageAdapter.Clone()创建 HeartbeatMessageAdapter 的副本 。
返回值: 收到了,我们得去查查
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)result = heartbeatMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)进程 & ###InnerAdapter+##输出消息.
- message
- 腾讯.
- cancellationToken
- 取消的代币。
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)result = heartbeatMessageAdapter.OnSendInMessageAsync(message, cancellationToken)发来消息
- message
- Message.
- cancellationToken
- CancellationToken
ProcessReconnection
public ValueTask ProcessReconnection(TimeSpan diff, CancellationToken cancellationToken)result = heartbeatMessageAdapter.ProcessReconnection(diff, cancellationToken)过程再连接逻辑.
- diff
- 上次检查已经过了一段时间了
- cancellationToken
- 取消的代币。
返回值: 任务