1 instantiation of IngestionResult
Microsoft.Extensions.DataIngestion (1)
IngestionPipeline.cs (1)
167yield return new IngestionResult(fileInfo, document, failure);
11 references to IngestionResult
Microsoft.Extensions.DataIngestion (5)
IngestionPipeline.cs (5)
80public async IAsyncEnumerable<IngestionResult> ProcessAsync(DirectoryInfo directory, string searchPattern = "*.*", 94await foreach (var ingestionResult in ProcessAsync(directory.EnumerateFiles(searchPattern, searchOption), rootActivity, cancellationToken).ConfigureAwait(false)) 107public async IAsyncEnumerable<IngestionResult> ProcessAsync(IEnumerable<FileInfo> files, [EnumeratorCancellation] CancellationToken cancellationToken = default) 113await foreach (var ingestionResult in ProcessAsync(files, rootActivity, cancellationToken).ConfigureAwait(false)) 128private async IAsyncEnumerable<IngestionResult> ProcessAsync(IEnumerable<FileInfo> files, Activity? rootActivity,
Microsoft.Extensions.DataIngestion.Tests (6)
IngestionPipelineTests.cs (6)
90List<IngestionResult> ingestionResults = await pipeline.ProcessAsync(_sampleFiles).ToListAsync(); 125List<IngestionResult> ingestionResults = await pipeline.ProcessAsync(directory, "*.md").ToListAsync(); 209async Task Verify(IAsyncEnumerable<IngestionResult> results) 211List<IngestionResult> ingestionResults = await results.ToListAsync(); 215IngestionResult ingestionResult = Assert.Single(ingestionResults.Where(result => !result.Succeeded)); 245private static void AssertAllIngestionsSucceeded(List<IngestionResult> ingestionResults)