HeartbeatMessageAdapter
StockSharp.Algo
The messages adapter controlling the connection.
Inherits: MessageAdapterWrapper
Constructors
HeartbeatMessageAdapter
public HeartbeatMessageAdapter(IMessageAdapter innerAdapter)heartbeatMessageAdapter = HeartbeatMessageAdapter(innerAdapter)Initializes a new instance of the HeartbeatMessageAdapter.
- innerAdapter
- Underlying adapter.
HeartbeatMessageAdapter
public HeartbeatMessageAdapter(IMessageAdapter innerAdapter, IHeartbeatManagerState state)heartbeatMessageAdapter = HeartbeatMessageAdapter(innerAdapter, state)Initializes a new instance of the HeartbeatMessageAdapter with explicit state.
- innerAdapter
- Underlying adapter.
- state
- State storage.
Properties
SuppressReconnectingErrors
public bool SuppressReconnectingErrors { get; set; }value = heartbeatMessageAdapter.SuppressReconnectingErrors
heartbeatMessageAdapter.SuppressReconnectingErrors = valueSuppress reconnecting errors.
Methods
Clone
public override IMessageAdapter Clone()result = heartbeatMessageAdapter.Clone()Create a copy of HeartbeatMessageAdapter.
Returns: Copy.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)result = heartbeatMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)Process InnerAdapter output message.
- message
- The message.
- cancellationToken
- Cancellation token.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)result = heartbeatMessageAdapter.OnSendInMessageAsync(message, cancellationToken)Send message.
- message
- Message.
- cancellationToken
- CancellationToken
ProcessReconnection
public ValueTask ProcessReconnection(TimeSpan diff, CancellationToken cancellationToken)result = heartbeatMessageAdapter.ProcessReconnection(diff, cancellationToken)Process reconnection logic.
- diff
- Time elapsed since last check.
- cancellationToken
- Cancellation token.
Returns: Task.