JsonRpcExtensions.WithPrefetchAsync<T> Método

Definición

Espacio de nombres:

StreamJsonRpc

Ensamblado:

StreamJsonRpc.dll

Paquete:

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

Carga previamente un IAsyncEnumerable<T> con una memoria caché de elementos enumerados previamente para su inclusión en la transmisión inicial del enumerador a través de un canal 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))

Parámetros de tipo

T

Tipo del elemento de la colección.

Parámetros

enumerable

IAsyncEnumerable<T>

Secuencia de la que se van a capturar previamente los elementos.

count

Int32

Número de elementos que se van a capturar previamente. Si este valor es mayor que el número de elementos del enumerador, se capturarán previamente todos los valores.

cancellationToken

CancellationToken

Token de cancelación.

Devoluciones

ValueTask<IAsyncEnumerable<T>>

Objeto decorado IAsyncEnumerable<T> especialmente preparado para su procesamiento por JSON-RPC con los valores precargados.