JsonRpcExtensions.WithPrefetchAsync<T> Metodo

Definizione

Spazio dei nomi:

StreamJsonRpc

Assembly:

StreamJsonRpc.dll

Pacchetto:

streamjsonrpc v2.10.44

Precarica un IAsyncEnumerable<T> oggetto con una cache di elementi preenumerati per l'inclusione nella trasmissione iniziale dell'enumerabile su un canale 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))

Parametri di tipo

T

Tipo di elemento contenuto nella raccolta.

Parametri

enumerable

IAsyncEnumerable<T>

Sequenza da cui recuperare gli elementi.

count

Int32

Numero di elementi da pre-recuperare. Se questo valore è maggiore del numero di elementi nell'enumerabile, tutti i valori verranno preletturati.

cancellationToken

CancellationToken

Token di annullamento.

Restituisce

ValueTask<IAsyncEnumerable<T>>

Oggetto decorato IAsyncEnumerable<T> preparato appositamente per l'elaborazione da JSON-RPC con i valori precaricati.