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