IngestionChunkProcessor<T>.ProcessAsync Metoda
Definicja
Ważne
Niektóre informacje odnoszą się do produktu w wersji wstępnej, który może zostać znacząco zmodyfikowany przed wydaniem. Firma Microsoft nie udziela żadnych gwarancji, jawnych lub domniemanych, w odniesieniu do informacji podanych w tym miejscu.
Przetwarza fragmenty asynchronicznie.
public abstract System.Collections.Generic.IAsyncEnumerable<Microsoft.Extensions.DataIngestion.IngestionChunk<T>> ProcessAsync(System.Collections.Generic.IAsyncEnumerable<Microsoft.Extensions.DataIngestion.IngestionChunk<T>> chunks, System.Threading.CancellationToken cancellationToken = default);
abstract member ProcessAsync : System.Collections.Generic.IAsyncEnumerable<Microsoft.Extensions.DataIngestion.IngestionChunk<'T>> * System.Threading.CancellationToken -> System.Collections.Generic.IAsyncEnumerable<Microsoft.Extensions.DataIngestion.IngestionChunk<'T>>
Public MustOverride Function ProcessAsync (chunks As IAsyncEnumerable(Of IngestionChunk(Of T)), Optional cancellationToken As CancellationToken = Nothing) As IAsyncEnumerable(Of IngestionChunk(Of T))
Parametry
- chunks
- IAsyncEnumerable<IngestionChunk<T>>
Fragmenty do przetworzenia.
- cancellationToken
- CancellationToken
Token do monitorowania żądań anulowania.
Zwraca
Przetworzone fragmenty.