ISubscriptionProviderAsyncExtensions

SubscribeAsync

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

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

Subscribe, wait for start, and keep it active until is canceled. On cancellation the method will call Subscription) and complete after the subscription is stopped.

provider

Subscription provider.

subscription

Subscription to manage.

cancellationToken

Cancellation token that triggers unsubscription.

Returns: A ValueTask that completes after the subscription is stopped (due to cancellation or failure).

SubscribeAsync``1

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

result = ISubscriptionProviderAsyncExtensions.SubscribeAsync(provider, subscription)

Subscribe and get an async stream of incoming data of type for the specified . Use .WithCancellation(token) to cancel, which triggers Subscription). The stream completes when the subscription stops or fails.

provider

Subscription provider.

subscription

Target subscription.

Returns: Async stream of incoming data objects for the given subscription filtered to .