18 references to ToAsyncEnumerable
Microsoft.Extensions.AI.Tests (4)
ChatCompletion\DistributedCachingChatClientTest.cs (3)
280
return actualUpdate.
ToAsyncEnumerable
();
324
GetStreamingResponseAsyncCallback = delegate { return expectedResponse.
ToAsyncEnumerable
(); }
402
GetStreamingResponseAsyncCallback = delegate { return expectedResponse.
ToAsyncEnumerable
(); }
ChatCompletion\ReducingChatClientTests.cs (1)
65
return expectedUpdates.
ToAsyncEnumerable
();
Microsoft.Extensions.DataIngestion.Tests (14)
IngestionPipelineTests.cs (1)
184
.
ToAsyncEnumerable
();
Processors\ClassificationEnricherTests.cs (2)
90
IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(CreateChunks().
ToAsyncEnumerable
()).ToListAsync();
111
IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(chunks.
ToAsyncEnumerable
()).ToListAsync();
Processors\KeywordEnricherTests.cs (2)
90
var chunks = CreateChunks().
ToAsyncEnumerable
();
111
IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(chunks.
ToAsyncEnumerable
()).ToListAsync();
Processors\SentimentEnricherTests.cs (2)
73
var input = CreateChunks().
ToAsyncEnumerable
();
98
IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(chunks.
ToAsyncEnumerable
()).ToListAsync();
Processors\SummaryEnricherTests.cs (2)
73
var input = CreateChunks().
ToAsyncEnumerable
();
95
IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(chunks.
ToAsyncEnumerable
()).ToListAsync();
Writers\VectorStoreWriterTests.cs (5)
42
await writer.WriteAsync(chunks.
ToAsyncEnumerable
());
88
await writer.WriteAsync(chunks.
ToAsyncEnumerable
());
107
await writer.WriteAsync(updatedChunks.
ToAsyncEnumerable
());
145
await writer.WriteAsync(chunks.
ToAsyncEnumerable
());
159
await writer.WriteAsync(updatedChunks.
ToAsyncEnumerable
());