IngestionChunkProcessor<T>.ProcessAsync Methode

Definition

Verarbeitet Datenblöcke asynchron.

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))

Parameter

chunks
IAsyncEnumerable<IngestionChunk<T>>

Die zu verarbeitenden Blöcke.

cancellationToken
CancellationToken

Das Token, das auf Abbruchanforderungen überwacht werden soll.

Gibt zurück

Die verarbeiteten Blöcke.

Gilt für: