Поделиться через


JsonRpcExtensions.WithPrefetchAsync<T> Метод

Определение

Предварительно загружает IAsyncEnumerable<T> кэш предварительно перечисляемых элементов для включения в начальную передачу перечисленного по каналу 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))

Параметры типа

T

Тип элементов в коллекции.

Параметры

enumerable
IAsyncEnumerable<T>

Последовательность для предварительной выборки элементов.

count
Int32

Количество элементов для предварительной выборки. Если это значение больше числа элементов в перечислении, все значения будут предварительно возвращены.

cancellationToken
CancellationToken

Токен отмены.

Возвращаемое значение

Украшенный IAsyncEnumerable<T> объект, специально подготовленный для обработки JSON-RPC с предварительно загруженными значениями.

Применяется к