HeartbeatMessageAdapter

StockSharp.Algo

控制连接的电文适配器。

构造函数

public HeartbeatMessageAdapter(IMessageAdapter innerAdapter)

heartbeatMessageAdapter = HeartbeatMessageAdapter(innerAdapter)

初始化了 & ##HeartbeatMessageAdapter+#的新实例.

public HeartbeatMessageAdapter(IMessageAdapter innerAdapter, IHeartbeatManagerState state)

heartbeatMessageAdapter = HeartbeatMessageAdapter(innerAdapter, state)

初始化了 & # #HeartbeatMessageAdapter # # 的新实例, 并带有明确的状态。

public bool SuppressReconnectingErrors { get; set; }

value = heartbeatMessageAdapter.SuppressReconnectingErrors
heartbeatMessageAdapter.SuppressReconnectingErrors = value

禁止重联错误.

CloneAsync

public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)

result = heartbeatMessageAdapter.CloneAsync(cancellationToken)

Create a copy of HeartbeatMessageAdapter.

返回值: Copy.

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = heartbeatMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

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

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = heartbeatMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

发来消息

public ValueTask ProcessHeartbeat(CancellationToken cancellationToken)

result = heartbeatMessageAdapter.ProcessHeartbeat(cancellationToken)

Probes the connection once nothing has been sent down it for the heartbeat interval.

返回值: Task.

public ValueTask ProcessReconnection(TimeSpan diff, CancellationToken cancellationToken)

result = heartbeatMessageAdapter.ProcessReconnection(diff, cancellationToken)

过程再连接逻辑.

返回值: 任务