4 overrides of ProcessAsync
Microsoft.Extensions.DataIngestion (4)
Processors\ClassificationEnricher.cs (1)
52public override IAsyncEnumerable<IngestionChunk<string>> ProcessAsync(IAsyncEnumerable<IngestionChunk<string>> chunks, CancellationToken cancellationToken = default)
Processors\KeywordEnricher.cs (1)
60public override IAsyncEnumerable<IngestionChunk<string>> ProcessAsync(IAsyncEnumerable<IngestionChunk<string>> chunks, CancellationToken cancellationToken = default)
Processors\SentimentEnricher.cs (1)
50public override IAsyncEnumerable<IngestionChunk<string>> ProcessAsync(IAsyncEnumerable<IngestionChunk<string>> chunks, CancellationToken cancellationToken = default)
Processors\SummaryEnricher.cs (1)
45public override IAsyncEnumerable<IngestionChunk<string>> ProcessAsync(IAsyncEnumerable<IngestionChunk<string>> chunks, CancellationToken cancellationToken = default)
1 reference to ProcessAsync
Microsoft.Extensions.DataIngestion (1)
IngestionPipeline.cs (1)
186chunks = processor.ProcessAsync(chunks, cancellationToken);