JsonRpcExtensions.WithPrefetchAsync<T> Yöntem

Tanım

Ad Alanı:

StreamJsonRpc

Bütünleştirilmiş Kod:

StreamJsonRpc.dll

Paket:

streamjsonrpc vD:\a\1\s\dotnet\nue-out\_pacmanada9c\StreamJsonRpc.2.9.85

Bir RPC kanalı üzerinden numaralandırılabilir öğesinin ilk iletimine dahil edilmesi için önceden numaralandırılmış öğelerden oluşan bir önbellekle önceden yükler IAsyncEnumerable<T> .

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ür Parametreleri

T

Koleksiyondaki öğenin türü.

Parametreler

enumerable

IAsyncEnumerable<T>

Öğeleri önceden getirme sırası.

count

Int32

Önceden getirilmeye hazır öğe sayısı. Bu değer numaralandırılabilir öğe sayısından büyükse, tüm değerler önceden getirilir.

cancellationToken

CancellationToken

İptal belirteci.

Döndürülenler

ValueTask<IAsyncEnumerable<T>>

Önceden yüklenmiş değerlerle JSON-RPC tarafından işlenmek üzere özel olarak hazırlanmış, süslü IAsyncEnumerable<T> bir nesne.