Use System.Linq.AsyncEnumerable package instead of System.Linq.Async

Copilot · adamsitnik · Copilot · commit 83b9f5d7da7e · 2025-11-12T09:57:27.000Z
Co-authored-by: adamsitnik &lt;6011991+adamsitnik@users.noreply.github.com&gt;
diff --git a/eng/packages/General.props b/eng/packages/General.props
@@ -32,7 +32,7 @@
     <PackageVersion Include="System.CommandLine.NamingConventionBinder" Version="2.0.0-beta4.22272.1" />
     <PackageVersion Include="System.CommandLine" Version="2.0.0-beta4.22272.1" />
     <PackageVersion Include="System.ComponentModel.Annotations" Version="5.0.0" />
-    <PackageVersion Include="System.Linq.Async" Version="7.0.0-preview.9" />
+    <PackageVersion Include="System.Linq.AsyncEnumerable" Version="10.0.0" />
     <PackageVersion Include="System.Memory" Version="4.5.5" />
     <PackageVersion Include="System.Private.Uri" Version="4.3.2" />
     <PackageVersion Include="System.Runtime.Caching" Version="$(SystemRuntimeCachingVersion)" />
diff --git a/src/Libraries/Microsoft.Extensions.DataIngestion/Microsoft.Extensions.DataIngestion.csproj b/src/Libraries/Microsoft.Extensions.DataIngestion/Microsoft.Extensions.DataIngestion.csproj
@@ -29,7 +29,7 @@
   </ItemGroup>
 
   <ItemGroup Condition="!$([MSBuild]::IsTargetFrameworkCompatible('$(TargetFramework)', 'net10.0'))">
-    <PackageReference Include="System.Linq.Async" />
+    <PackageReference Include="System.Linq.AsyncEnumerable" />
   </ItemGroup>
 
 </Project>
diff --git a/test/Libraries/Microsoft.Extensions.AI.Tests/ChatCompletion/DistributedCachingChatClientTest.cs b/test/Libraries/Microsoft.Extensions.AI.Tests/ChatCompletion/DistributedCachingChatClientTest.cs
@@ -276,7 +276,7 @@ public async Task StreamingCachesSuccessResultsAsync(bool conversationIdSet)
             GetStreamingResponseAsyncCallback = delegate
             {
                 innerCallCount++;
-                return ToAsyncEnumerableAsync(actualUpdate);
+                return actualUpdate.ToAsyncEnumerable();
             }
         };
         using var outer = new DistributedCachingChatClient(testClient, _storage)
@@ -320,7 +320,7 @@ public async Task StreamingCoalescesConsecutiveTextChunksAsync(bool? coalesce)
 
         using var testClient = new TestChatClient
         {
-            GetStreamingResponseAsyncCallback = delegate { return ToAsyncEnumerableAsync(expectedResponse); }
+            GetStreamingResponseAsyncCallback = delegate { return expectedResponse.ToAsyncEnumerable(); }
         };
         using var outer = new DistributedCachingChatClient(testClient, _storage)
         {
@@ -398,7 +398,7 @@ public async Task StreamingCoalescingPropagatesMetadataAsync()
 
         using var testClient = new TestChatClient
         {
-            GetStreamingResponseAsyncCallback = delegate { return ToAsyncEnumerableAsync(expectedResponse); }
+            GetStreamingResponseAsyncCallback = delegate { return expectedResponse.ToAsyncEnumerable(); }
         };
         using var outer = new DistributedCachingChatClient(testClient, _storage)
         {
@@ -772,9 +772,6 @@ private static async Task<List<T>> ToListAsync<T>(IAsyncEnumerable<T> values)
         return result;
     }
 
-    private static IAsyncEnumerable<T> ToAsyncEnumerableAsync<T>(IEnumerable<T> values)
-        => values.ToAsyncEnumerable();
-
     private static IAsyncEnumerable<T> ToAsyncEnumerableAsync<T>(Task preTask, IEnumerable<T> valueFactories)
         => ToAsyncEnumerableAsync(preTask, valueFactories.Select<T, Func<T>>(v => () => v));
 
diff --git a/test/Libraries/Microsoft.Extensions.AI.Tests/Microsoft.Extensions.AI.Tests.csproj b/test/Libraries/Microsoft.Extensions.AI.Tests/Microsoft.Extensions.AI.Tests.csproj
@@ -32,7 +32,7 @@
   </ItemGroup>
 
   <ItemGroup Condition="!$([MSBuild]::IsTargetFrameworkCompatible('$(TargetFramework)', 'net10.0'))">
-    <PackageReference Include="System.Linq.Async" />
+    <PackageReference Include="System.Linq.AsyncEnumerable" />
   </ItemGroup>
 
   <ItemGroup>
diff --git a/test/Libraries/Microsoft.Extensions.DataIngestion.Tests/Microsoft.Extensions.DataIngestion.Tests.csproj b/test/Libraries/Microsoft.Extensions.DataIngestion.Tests/Microsoft.Extensions.DataIngestion.Tests.csproj
@@ -27,10 +27,6 @@
     <PackageReference Include="OpenTelemetry.Exporter.InMemory" />
   </ItemGroup>
 
-  <ItemGroup Condition="!$([MSBuild]::IsTargetFrameworkCompatible('$(TargetFramework)', 'net10.0'))">
-    <PackageReference Include="System.Linq.Async" />
-  </ItemGroup>
-
   <ItemGroup>
     <Compile Include="..\Microsoft.Extensions.AI.Abstractions.Tests\TestChatClient.cs" />
     <Compile Include="..\Microsoft.Extensions.AI.Abstractions.Tests\TestEmbeddingGenerator.cs" />

Original file line number	Diff line number	Diff line change
`@@ -276,7 +276,7 @@ public async Task StreamingCachesSuccessResultsAsync(bool conversationIdSet)`
`276`	`276`	`GetStreamingResponseAsyncCallback = delegate`
`277`	`277`	`{`
`278`	`278`	`innerCallCount++;`
`279`		`- return ToAsyncEnumerableAsync(actualUpdate);`
	`279`	`+ return actualUpdate.ToAsyncEnumerable();`
`280`	`280`	`}`
`281`	`281`	`};`
`282`	`282`	`using var outer = new DistributedCachingChatClient(testClient, _storage)`
`@@ -320,7 +320,7 @@ public async Task StreamingCoalescesConsecutiveTextChunksAsync(bool? coalesce)`
`320`	`320`
`321`	`321`	`using var testClient = new TestChatClient`
`322`	`322`	`{`
`323`		`- GetStreamingResponseAsyncCallback = delegate { return ToAsyncEnumerableAsync(expectedResponse); }`
	`323`	`+ GetStreamingResponseAsyncCallback = delegate { return expectedResponse.ToAsyncEnumerable(); }`
`324`	`324`	`};`
`325`	`325`	`using var outer = new DistributedCachingChatClient(testClient, _storage)`
`326`	`326`	`{`
`@@ -398,7 +398,7 @@ public async Task StreamingCoalescingPropagatesMetadataAsync()`
`398`	`398`
`399`	`399`	`using var testClient = new TestChatClient`
`400`	`400`	`{`
`401`		`- GetStreamingResponseAsyncCallback = delegate { return ToAsyncEnumerableAsync(expectedResponse); }`
	`401`	`+ GetStreamingResponseAsyncCallback = delegate { return expectedResponse.ToAsyncEnumerable(); }`
`402`	`402`	`};`
`403`	`403`	`using var outer = new DistributedCachingChatClient(testClient, _storage)`
`404`	`404`	`{`
`@@ -772,9 +772,6 @@ private static async Task<List<T>> ToListAsync<T>(IAsyncEnumerable<T> values)`
`772`	`772`	`return result;`
`773`	`773`	`}`
`774`	`774`
`775`		`- private static IAsyncEnumerable<T> ToAsyncEnumerableAsync<T>(IEnumerable<T> values)`
`776`		`- => values.ToAsyncEnumerable();`
`777`		`-`
`778`	`775`	`private static IAsyncEnumerable<T> ToAsyncEnumerableAsync<T>(Task preTask, IEnumerable<T> valueFactories)`
`779`	`776`	`=> ToAsyncEnumerableAsync(preTask, valueFactories.Select<T, Func<T>>(v => () => v));`
`780`	`777`