JsonRpcExtensions.WithPrefetchAsync<T> Método

Definição

Namespace:

StreamJsonRpc

Assembly:

StreamJsonRpc.dll

Pacote:

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

Pré-carrega um IAsyncEnumerable<T> com um cache de itens pré-enumerados para inclusão na transmissão inicial do enumerável em um 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

O tipo de item na coleção.

Parâmetros

enumerable

IAsyncEnumerable<T>

A sequência da qual buscar itens previamente.

count

Int32

O número de itens a serem buscados previamente. Se esse valor for maior que o número de elementos na enumerável, todos os valores serão pré-buscados.

cancellationToken

CancellationToken

Um token de cancelamento.

Retornos

ValueTask<IAsyncEnumerable<T>>

Um objeto decorado IAsyncEnumerable<T> especialmente preparado para processamento por JSON-RPC com os valores pré-carregados.