SubscriptionOnlineManager
StockSharp.Algo
Aplicación de procesamiento de suscripción en línea.
Implementa: ISubscriptionOnlineManager
Constructores
SubscriptionOnlineManager
public SubscriptionOnlineManager(ILogReceiver logReceiver, Func<DataType, bool> isSecurityRequired, ISubscriptionOnlineManagerState state)subscriptionOnlineManager = SubscriptionOnlineManager(logReceiver, isSecurityRequired, state)Aplicación de procesamiento de suscripción en línea.
- logReceiver
- Receptor de registro.
- isSecurityRequired
- Compruebe si se requiere un id de instrumento financiero para el tipo de datos especificado.
- state
- Almacenamiento estatal.
Propiedades
State
public ISubscriptionOnlineManagerState State { get; }value = subscriptionOnlineManager.StateAlmacenamiento estatal.
Métodos
ProcessInMessageAsync
public ValueTask<ValueTuple<Message[], Message[]>> ProcessInMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessInMessageAsync(message, cancellationToken)Procesar un mensaje entrando en el adaptador interno.
- message
- Mensaje entrante.
- cancellationToken
- Cancelación token.
Devuelve: Resultado de procesamiento.
ProcessOutMessageAsync
public ValueTask<ValueTuple<Message, Message[]>> ProcessOutMessageAsync(Message message, CancellationToken cancellationToken)result = subscriptionOnlineManager.ProcessOutMessageAsync(message, cancellationToken)Procesar un mensaje que viene del adaptador interno.
- message
- Mensaje saliente.
- cancellationToken
- Cancelación token.
Devuelve: Resultado de procesamiento.