IMessageAdapterAsyncExtensions — StockSharp Documentación

ConnectAndDownloadAsync``1

public static IAsyncEnumerable<T> ConnectAndDownloadAsync<T>(IMessageAdapter adapter, ISubscriptionMessage subscription)

result = IMessageAdapterAsyncExtensions.ConnectAndDownloadAsync(adapter, subscription)

Conectar, suscribir y obtener un flujo asinc de mensajes, luego desconectar la terminación. Este es un método de conveniencia que maneja el ciclo de vida completo: conectar - oh suscribirse - títulos de descuento.

adapter: IMessageAdapter
subscription: ISubscriptionMessage

Devuelve: Flujo de mensajes Async.

ConnectAsync

public static ValueTask ConnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.ConnectAsync(adapter, cancellationToken)

Async connect for IMessageAdapter via ConnectMessage. Completa cuando se recibe un ConnectMessage saliente sin error.

adapter: IMessageAdapter
cancellationToken: CancellationToken

Devuelve: ValueTask

DisconnectAsync

public static ValueTask DisconnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.DisconnectAsync(adapter, cancellationToken)

Desconexión Async para IMessageAdapter vía DisconnectMessage. Completa cuando se recibe un DisconnectMessage saliente sin error.

adapter: IMessageAdapter
cancellationToken: CancellationToken

Devuelve: ValueTask

RegisterOrderAndWaitAsync

public static IAsyncEnumerable<ExecutionMessage> RegisterOrderAndWaitAsync(IMessageAdapter adapter, OrderRegisterMessage order)

result = IMessageAdapterAsyncExtensions.RegisterOrderAndWaitAsync(adapter, order)

Orden de registro y obtener una secuencia asinc de ExecutionMessage@ (actuaciones del estado de orden y comercios propios).Cuando se cancela la ficha de cancelación (a través de .WithCancellation(token)), se cancela el pedido automáticamente. Completa cuando el pedido llega a un estado final (Done o Failed).

adapter: IMessageAdapter
order: OrderRegisterMessage para registrarse.

Devuelve: Flujo Async de ExecutionMessage@ con información de pedidos y comercios.

SubscribeAsync

public static ValueTask SubscribeAsync(IMessageAdapter adapter, ISubscriptionMessage subscription, CancellationToken cancellationToken)

result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription, cancellationToken)

Suscribir, esperar para el inicio/acabado, y mantenerlo activo hasta que se cancele. Para las suscripciones históricas terminadas, para los acabados en vivo después de la cancelación y el descríbete procesado.

adapter: IMessageAdapter
subscription: ISubscriptionMessage
cancellationToken: CancellationToken

Devuelve: ValueTask

SubscribeAsync``1

public static IAsyncEnumerable<T> SubscribeAsync<T>(IMessageAdapter adapter, ISubscriptionMessage subscription)

result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription)

Suscríbete y consigue una secuencia de mensajes de datos salientes de tipo asociado con el dado . Use .WithCancellation(token) para pasar la ficha de cancelación.

adapter: IMessageAdapter
subscription: ISubscriptionMessage

Devuelve: Flujo de mensajes Async.