SubscriptionOnlineManager
StockSharp.Algo
Реализация обработки онлайн-подписки.
Реализует: ISubscriptionOnlineManager
Конструкторы
SubscriptionOnlineManager
public SubscriptionOnlineManager(ILogReceiver logReceiver, Func<DataType, bool> isSecurityRequired, ISubscriptionOnlineManagerState state)subscriptionOnlineManager = SubscriptionOnlineManager(logReceiver, isSecurityRequired, state)Реализация обработки онлайн-подписки.
- logReceiver
- Приемник журналов.
- isSecurityRequired
- Проверьте, требуется ли идентификатор финансового инструмента для указанного типа данных.
- state
- Государственное хранилище.
Свойства
State
public ISubscriptionOnlineManagerState State { get; }value = subscriptionOnlineManager.StateГосударственное хранилище.
Методы
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessInMessageAsync(message, cancellationToken)Обработать сообщение, поступающее во внутренний адаптер.
- message
- Входящее сообщение.
- cancellationToken
- Токен отмены.
Возвращает: Результат обработки.
ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessOutMessageAsync(message, cancellationToken)Обработать сообщение, поступающее от внутреннего адаптера.
- message
- Исходящее сообщение.
- cancellationToken
- Токен отмены.
Возвращает: Результат обработки.