SubscriptionMessageAdapter

StockSharp.Algo

Subscription counter adapter.

Inherits: MessageAdapterWrapper

Constructors

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

Initializes a new instance of the SubscriptionMessageAdapter.

innerAdapter
Inner message adapter.
SubscriptionMessageAdapter
public SubscriptionMessageAdapter(IMessageAdapter innerAdapter, ISubscriptionManager manager)
subscriptionMessageAdapter = SubscriptionMessageAdapter(innerAdapter, manager)

Initializes a new instance of the SubscriptionMessageAdapter with a custom manager.

innerAdapter
Inner message adapter.
manager
Subscription manager.

Properties

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

Restore subscription on reconnect.

Methods

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

Create a copy of SubscriptionMessageAdapter.

Returns: Copy.

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

Process InnerAdapter output message.

message
The message.
cancellationToken
Cancellation token.
OnInnerAdapterNewOutMessageAsync
protected override ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnInnerAdapterNewOutMessageAsync(message, cancellationToken)

Process InnerAdapter output message.

message
The message.
cancellationToken
Cancellation token.
OnSendInMessageAsync
protected override ValueTask OnSendInMessageAsync(Message message, CancellationToken cancellationToken)
result = subscriptionMessageAdapter.OnSendInMessageAsync(message, cancellationToken)

Send message.

message
Message.
cancellationToken
CancellationToken