Merge pull request Cysharp#468 from NepPure/patch-1

Update smple code "await foreach"

README.md

@@ -1432,10 +1432,10 @@ public class MyFirstService : ServiceBase<IMyFirstService>, IMyFirstService
         var stream = GetClientStreamingContext<int, string>();
 
         // receive from client asynchronously
-        await stream.ForEachAsync(x =>
+        await foreach (var x in stream.ReadAllAsync())
         {
             Logger.Debug("Client Stream Received:" + x);
-        });
+        }
 
         // StreamingContext.Result() for result value.
         return stream.Result("finished");
@@ -1467,10 +1467,10 @@ public class MyFirstService : ServiceBase<IMyFirstService>, IMyFirstService
         var waitTask = Task.Run(async () =>
         {
             // ForEachAsync(MoveNext, Current) can receive client streaming.
-            await stream.ForEachAsync(x =>
+            await foreach (var x in stream.ReadAllAsync())
             {
                 Logger.Debug($"Duplex Streaming Received:" + x);
-            });
+            }
         });
 
         // WriteAsync is ServerStreaming.
@@ -1517,18 +1517,18 @@ static async Task ServerStreamRun(IMyFirstService client)
 {
     var stream = await client.ServerStreamingSampleAsync(10, 20, 3);
 
-    await stream.ResponseStream.ForEachAsync(x =>
+    await foreach (var x in stream.ResponseStream.ReadAllAsync())
     {
         Console.WriteLine("ServerStream Response:" + x);
-    });
+    }
 }
 
 static async Task DuplexStreamRun(IMyFirstService client)
 {
     var stream = await client.DuplexStreamingSampleAsync();
 
     var count = 0;
-    await stream.ResponseStream.ForEachAsync(async x =>
+    await foreach (var x in stream.ResponseStream.ReadAllAsync())
     {
         Console.WriteLine("DuplexStream Response:" + x);
 
@@ -1537,7 +1537,7 @@ static async Task DuplexStreamRun(IMyFirstService client)
         {
             await stream.RequestStream.CompleteAsync();
         }
-    });
+    }
 }
 ```
 

tests/MagicOnion.Server.Tests/MagicOnion.Server.Tests.csproj

@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <TargetFramework>net6.0</TargetFramework>
-
+    <LangVersion>default</LangVersion>
     <IsPackable>false</IsPackable>
   </PropertyGroup>
 

tests/MagicOnion.Server.Tests/Tests/SimpleTest.cs

@@ -1,4 +1,4 @@
-using Grpc.Core;
+using Grpc.Core;
 using MagicOnion.Client;
 using MagicOnion.Server;
 using System;
@@ -45,10 +45,10 @@ public async Task<ClientStreamingResult<int, string>> ClientStreaming1Task()
             var streaming = GetClientStreamingContext<int, string>();
 
             var list = new List<int>();
-            await streaming.ForEachAsync(x =>
+            await foreach (var x in streaming.ReadAllAsync())
             {
                 list.Add(x);
-            });
+            }
 
             return streaming.Result("finished:" + string.Join(", ", list));
         }
@@ -65,9 +65,9 @@ public async Task<DuplexStreamingResult<int, string>> DuplexStreaming1Task()
 
             var l = new List<int>();
 
-            while (await stream.MoveNext())
+            await foreach (var x in stream.ReadAllAsync())
             {
-                l.Add(stream.Current);
+                l.Add(x);
                 await stream.WriteAsync(string.Join(", ", l));
             }
 
@@ -138,7 +138,7 @@ public async Task Unary()
             r.Should().Be(30);
 
             var r0 = await client.Unary1Task(1000, 2000);
-            var r2 = await r0; 
+            var r2 = await r0;
             r2.Should().Be(3000);
         }