SubscriptionMessageAdapter — StockSharp.Algo

Конструкторы

public SubscriptionMessageAdapter(IMessageAdapter innerAdapter)

subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter)

Инициализирует новый экземпляр SubscriptionMessageAdapter.

public SubscriptionMessageAdapter(IMessageAdapter innerAdapter, ISubscriptionManager manager)

subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter, manager)

Инициализирует новый экземпляр SubscriptionMessageAdapter с помощью специального менеджера.

public bool IsRestoreSubscriptionOnErrorReconnect { get; set; }

value = subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect
subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect = value

Восстановить подписку на Reconnect.

CloneAsync

public override ValueTask<IMessageAdapter> CloneAsync(CancellationToken cancellationToken)

result = subscriptionMessageAdapter.CloneAsync(cancellationToken)

Create a copy of SubscriptionMessageAdapter.

Возвращает: Copy.

protected override ValueTask InnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = subscriptionMessageAdapter.InnerAdapterNewOutMessageAsync(message, cancellationToken)

Обработать выходное сообщение InnerAdapter.

protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

result = subscriptionMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Обработать выходное сообщение InnerAdapter.

protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)

result = subscriptionMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Отправить сообщение.