Base:
method
ProcessAsync
Microsoft.Extensions.DataIngestion.IngestionChunkProcessor<T>.ProcessAsync(System.Collections.Generic.IAsyncEnumerable<Microsoft.Extensions.DataIngestion.IngestionChunk<T>>, System.Threading.CancellationToken)
3 references to ProcessAsync
Microsoft.Extensions.DataIngestion.Tests (3)
Processors\ClassificationEnricherTests.cs (3)
58await foreach (var _ in sut.ProcessAsync(null!)) 90IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(CreateChunks().ToAsyncEnumerable()).ToListAsync(); 111IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(chunks.ToAsyncEnumerable()).ToListAsync();