ISubscriptionProviderAsyncExtensions

SubscribeAsync

public static ValueTask SubscribeAsync(ISubscriptionProvider provider, Subscription subscription, CancellationToken cancellationToken)

result = ISubscriptionProviderAsyncExtensions.SubscribeAsync(provider, subscription, cancellationToken)

Suscribir, esperar para comenzar, y mantenerlo activo hasta que se cancele. Al cancelar el método llamará la suscripción) y completar después de que la suscripción se detenga.

provider

Proveedor de suscripción.

subscription

Suscripción para administrar.

cancellationToken

Cancelación de token que desencadena la suscripción.

Devuelve: A ValueTask que termina después de la suscripción se detiene (debido a cancelación o fracaso).

SubscribeAsync``1

public static IAsyncEnumerable<T> SubscribeAsync<T>(ISubscriptionProvider provider, Subscription subscription)

result = ISubscriptionProviderAsyncExtensions.SubscribeAsync(provider, subscription)

Suscríbete y consigue una secuencia de datos entrantes de tipo para el especificado . Use .WithCancellation(token) para cancelar, lo que activa la suscripción). El flujo se completa cuando la suscripción se detiene o falla.

provider

Proveedor de suscripción.

subscription

Suscripción de objetivos.

Devuelve: Flujo de Async de objetos de datos entrantes para la suscripción dada filtrada a .