ISubscriptionProviderAsyncExtensions

SubscribeAsync

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

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

Подпишитесь, дождитесь начала и сохраняйте активность до отмены. При отмене метод вызовет Subscription) и завершится после остановки подписки.

provider

Поставщик подписки.

subscription

Подписка для управления.

cancellationToken

Токен отмены, запускающий отмену подписки.

Возвращает: ValueTask, который завершается после остановки подписки (из-за отмены или сбоя).

SubscribeAsync``1

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

result = ISubscriptionProviderAsyncExtensions.SubscribeAsync(provider, subscription)

Подпишитесь и получите асинхронный поток входящих данных типа для указанного . Используйте .WithCancellation(токен) для отмены, что активирует подписку). Поток завершается, когда подписка останавливается или происходит сбой.

provider

Поставщик подписки.

subscription

Целевая подписка.

Возвращает: Асинхронный поток входящих объектов данных для данной подписки фильтруется до .