ISubscriptionProviderAsyncExtensions

SubscribeAsync

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

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

Abonnieren, warten Sie auf den Start und halten Sie es aktiv, bis es storniert wird. Bei der Kündigung wird die Methode Abonnement aufrufen und nach Beendigung des Abonnements abgeschlossen.

provider

Subscription Provider.

subscription

Subscription zum Verwalten.

cancellationToken

Stornierungstoken, der die Abmeldung auslöst.

Rückgabe: Ein ValueTask, das nach Beendigung des Abonnements abgeschlossen wird (aufgrund von Stornierung oder Ausfall).

SubscribeAsync``1

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

result = ISubscriptionProviderAsyncExtensions.SubscribeAsync(provider, subscription)

Abonnieren und erhalten Sie einen async-Stream von eingehenden Daten des Typs für die angegebenen . Verwenden Sie .WithCancellation(Token) zum Abbrechen, was das Abonnement auslöst. Der Stream ist abgeschlossen, wenn das Abonnement stoppt oder fehlschlägt.

provider

Subscription Provider.

subscription

Zielabonnement.

Rückgabe: Async-Stream von eingehenden Datenobjekten für das jeweilige Abonnement, gefiltert nach .