- 增加 ISelect.ToChunkAsyncEnumerable 异步流功能；#1982 #2015 #1952 #1674 #1520 #949 #360 #488 #190 #167

2026-02-06 16:30:52 +08:00 · 2025-04-24 19:10:18 +08:00
parent 5625fe1e07
commit 61895079fe
12 changed files with 2618 additions and 2394 deletions
--- a/Examples/base_entity/Program.cs
+++ b/Examples/base_entity/Program.cs
@@ -621,6 +621,17 @@ namespace base_entity
            BaseEntity.Initialization(fsql, () => _asyncUow.Value);
            #endregion

+            Task.Run(async () =>
+            {
+                await foreach (var xxs1 in fsql.Select<User1>().ToChunkAsyncEnumerable(10))
+                {
+                    foreach (var item in xxs1)
+                    {
+                        Console.WriteLine(item.Nickname);
+                    }
+                }
+            }).Wait();
+
            Utils.IsStrict = false;
            var user1Tb = fsql.CodeFirst.GetTableByEntity(typeof(User11));