JsonRpcExtensions.WithPrefetchAsync<T> Metoda

Definicja

Przestrzeń nazw:

StreamJsonRpc

Zestaw:

StreamJsonRpc.dll

Pakiet:

streamjsonrpc v2.10.44

Wstępnie ładuje element IAsyncEnumerable<T> z pamięcią podręczną wstępnie wyliczone elementy do włączenia do początkowej transmisji wyliczanej przez kanał 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))

Parametry typu

T

Typ elementu w kolekcji.

Parametry

enumerable

IAsyncEnumerable<T>

Sekwencja pobierania elementów wstępnie.

count

Int32

Liczba elementów do pobrania wstępnego. Jeśli ta wartość jest większa niż liczba elementów w wyliczaniu, wszystkie wartości zostaną wstępnie pobrane.

cancellationToken

CancellationToken

Token anulowania.

Zwraca

ValueTask<IAsyncEnumerable<T>>

Ozdobiony IAsyncEnumerable<T> obiekt, który jest specjalnie przygotowany do przetwarzania przez JSON-RPC z wstępnie załadowanymi wartościami.