IMessageAdapterAsyncExtensions
Extensões de sincronização para IMessageAdapter.
Métodos
public static IAsyncEnumerable<T> ConnectAndDownloadAsync<T>(IMessageAdapter adapter, ISubscriptionMessage subscription)result = IMessageAdapterAsyncExtensions.ConnectAndDownloadAsync(adapter, subscription)Conecte, assine e obtenha um fluxo assync de mensagens, então desconecte ao completar. Este é um método de conveniência que lida com o ciclo de vida completo: connect -> subscreva -> desconecte.
- adapter
- IMessageAdapter
- subscription
- ISubscriptionMessage
Retorna: Sincronizar o fluxo de mensagens.
public static ValueTask ConnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)result = IMessageAdapterAsyncExtensions.ConnectAsync(adapter, cancellationToken)Assync connect for IMessageAdapter via ConnectMessage. Completa quando uma saída ConnectMessage sem erro é recebida.
- adapter
- IMessageAdapter
- cancellationToken
- CancellationToken
Retorna: ValueTask
public static ValueTask DisconnectAsync(IMessageAdapter adapter, CancellationToken cancellationToken)result = IMessageAdapterAsyncExtensions.DisconnectAsync(adapter, cancellationToken)Desconexão assincronizada para IMessageAdapter via DisconnectMessage. Termina quando uma saída DisconnectMessage sem erro é recebida.
- adapter
- IMessageAdapter
- cancellationToken
- CancellationToken
Retorna: ValueTask
public static IAsyncEnumerable<ExecutionMessage> RegisterOrderAndWaitAsync(IMessageAdapter adapter, OrderRegisterMessage order)result = IMessageAdapterAsyncExtensions.RegisterOrderAndWaitAsync(adapter, order)Registre a ordem e obtenha uma sequência assinc de ExecutionMessage (alterações de estado da ordem e comércio próprio). Quando o token de cancelamento (via .WithCancellation (token)) é cancelado, a ordem é cancelada automaticamente. Termina quando a ordem atinge um estado final (Feito ou Falhou).
- adapter
- IMessageAdapter
- order
- OrderRegisterMessage para se registar.
Retorna: Assincronização de ExecutionMessage com informações de ordem e transações.
public static ValueTask SubscribeAsync(IMessageAdapter adapter, ISubscriptionMessage subscription, CancellationToken cancellationToken)result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription, cancellationToken)Subscreva- se, aguarde o início/terminação e mantenha- o activo até ser cancelado. Para as assinaturas históricas concluídas, para as completas ao vivo após o cancelamento e a anulação da subscrição processada.
- adapter
- IMessageAdapter
- subscription
- ISubscriptionMessage
- cancellationToken
- CancellationToken
Retorna: ValueTask
public static IAsyncEnumerable<T> SubscribeAsync<T>(IMessageAdapter adapter, ISubscriptionMessage subscription)result = IMessageAdapterAsyncExtensions.SubscribeAsync(adapter, subscription)Assine e obtenha um fluxo assync de mensagens de dados de saída do tipo associado ao dado . Use .WithCancellation(token) para passar token cancelamento.
- adapter
- IMessageAdapter
- subscription
- ISubscriptionMessage
Retorna: Sincronizar o fluxo de mensagens.