26 references to ToAsyncEnumerable
Microsoft.AspNetCore.Http.Results.Tests (10)
ServerSentEventsResultTests.cs (10)
44var events = new[] { "event1\"with\"quotes", "event2" }.ToAsyncEnumerable(); 65var events = new[] { "event1", "event2" }.ToAsyncEnumerable(); 82var events = new[] { new SseItem<string>("event1", "custom-event") }.ToAsyncEnumerable(); 111var events = new string[] { null }.ToAsyncEnumerable(); 146var events = new[] { testObject }.ToAsyncEnumerable(); 163var events = new[] { new SseItem<TestObject>(testObject) }.ToAsyncEnumerable(); 191var events = new[] { testObject }.ToAsyncEnumerable(); 208var events = new TestObject[] { baseClass }.ToAsyncEnumerable(); 292var events = new[] { new SseItem<byte[]>(bytes) }.ToAsyncEnumerable(); 311var events = new[] { new SseItem<byte[]>(null) }.ToAsyncEnumerable();
Microsoft.Extensions.AI.Tests (4)
ChatCompletion\DistributedCachingChatClientTest.cs (3)
279return actualUpdate.ToAsyncEnumerable(); 323GetStreamingResponseAsyncCallback = delegate { return expectedResponse.ToAsyncEnumerable(); } 401GetStreamingResponseAsyncCallback = delegate { return expectedResponse.ToAsyncEnumerable(); }
ChatCompletion\ReducingChatClientTests.cs (1)
65return expectedUpdates.ToAsyncEnumerable();
Microsoft.Extensions.DataIngestion.Tests (12)
IngestionPipelineTests.cs (1)
184.ToAsyncEnumerable();
Processors\ClassificationEnricherTests.cs (2)
90IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(CreateChunks().ToAsyncEnumerable()).ToListAsync(); 111IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(chunks.ToAsyncEnumerable()).ToListAsync();
Processors\KeywordEnricherTests.cs (2)
90var chunks = CreateChunks().ToAsyncEnumerable(); 111IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(chunks.ToAsyncEnumerable()).ToListAsync();
Processors\SentimentEnricherTests.cs (2)
73var input = CreateChunks().ToAsyncEnumerable(); 98IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(chunks.ToAsyncEnumerable()).ToListAsync();
Processors\SummaryEnricherTests.cs (2)
73var input = CreateChunks().ToAsyncEnumerable(); 95IReadOnlyList<IngestionChunk<string>> got = await sut.ProcessAsync(chunks.ToAsyncEnumerable()).ToListAsync();
Writers\VectorStoreWriterTests.cs (3)
42await writer.WriteAsync(chunks.ToAsyncEnumerable()); 88await writer.WriteAsync(chunks.ToAsyncEnumerable()); 107await writer.WriteAsync(updatedChunks.ToAsyncEnumerable());