SubscriptionMessageAdapter

StockSharp.Algo

Адаптер счетчика подписки.

Наследует: MessageAdapterWrapper

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

SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter)

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

innerAdapter
Внутренний адаптер сообщений.
SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter, ISubscriptionManager manager)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter, manager)

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

innerAdapter
Внутренний адаптер сообщений.
manager
Менеджер по подписке.

Свойства

IsRestoreSubscriptionOnErrorReconnect
public bool IsRestoreSubscriptionOnErrorReconnect { get; set; }
value = subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect
subscriptionMessageAdapter.IsRestoreSubscriptionOnErrorReconnect = value

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

Методы

Clone
public override IMessageAdapter Clone()
result = subscriptionMessageAdapter.Clone()

Создайте копию SubscriptionMessageAdapter.

Возвращает: Копия.

InnerAdapterNewOutMessageAsync
protected override ValueTask InnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.InnerAdapterNewOutMessageAsync(message, cancellationToken)

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

message
Сообщение.
cancellationToken
Токен отмены.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

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

message
Сообщение.
cancellationToken
Токен отмены.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

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

message
Message.
cancellationToken
CancellationToken