JsonRpcExtensions.WithPrefetchAsync<T> メソッド

定義

名前空間:

StreamJsonRpc

アセンブリ:

StreamJsonRpc.dll

パッケージ:

streamjsonrpc v2.10.44

IAsyncEnumerable<T> RPC チャネルを介した列挙可能な列挙の初期転送に含めるために、事前列挙項目のキャッシュを事前に読み込みます。

public static System.Threading.Tasks.ValueTask<System.Collections.Generic.IAsyncEnumerable<T>> WithPrefetchAsync<T>(this System.Collections.Generic.IAsyncEnumerable<T> enumerable, int count, System.Threading.CancellationToken cancellationToken = default);

static member WithPrefetchAsync : System.Collections.Generic.IAsyncEnumerable<'T> * int * System.Threading.CancellationToken -> System.Threading.Tasks.ValueTask<System.Collections.Generic.IAsyncEnumerable<'T>>

<Extension()>
Public Function WithPrefetchAsync(Of T) (enumerable As IAsyncEnumerable(Of T), count As Integer, Optional cancellationToken As CancellationToken = Nothing) As ValueTask(Of IAsyncEnumerable(Of T))

型パラメーター

T

コレクション内の項目の型。

パラメーター

enumerable

IAsyncEnumerable<T>

項目をプリフェッチするシーケンス。

count

Int32

プリフェッチする項目の数。 この値が列挙可能な要素の数より大きい場合、すべての値が事前にフェッチされます。

cancellationToken

CancellationToken

キャンセル トークン。

戻り値

ValueTask<IAsyncEnumerable<T>>

プリロードされた値を IAsyncEnumerable<T> 使用して JSON-RPC による処理用に特別に準備された装飾オブジェクト。