ISubscriptionProviderAsyncExtensions

SubscribeAsync

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

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

サブスクリプションを購読し、開始を待ち、キャンセルするまで有効に保ちます。キャンセル時に、サブスクリプションが停止した後にメソッドがサブスクリプションを呼び出します。

provider

サブスクリプションプロバイダー。

subscription

管理するためのサブスクリプション。

cancellationToken

サブスクリプションをトリガーするキャンセルトークン。

戻り値: サブスクリプションが停止した後に完了する@ValueTask@(キャンセルまたは失敗する)。

SubscribeAsync``1

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

result = ISubscriptionProviderAsyncExtensions.SubscribeAsync(provider, subscription)

指定したタイプの入力データの非同期ストリームを購読して取得します。 .WithCancellation(トークン) を使用して、サブスクリプションをトリガーします。 サブスクリプションが停止または失敗したときにストリームが完成します。

provider

サブスクリプションプロバイダー。

subscription

ターゲットサブスクリプション。

戻り値: 指定したサブスクリプションがフィルタリングされたデータオブジェクトの非同期ストリーム。