updated samples and unit tests

kerryjiang · Apr 15, 2024 · 6e33402 · 6e33402
1 parent 24dcc13
commit 6e33402
Show file tree

Hide file tree

Showing 6 changed files with 8 additions and 8 deletions.
diff --git a/samples/CommandServer/ADD.cs b/samples/CommandServer/ADD.cs
@@ -18,7 +18,7 @@ public async ValueTask ExecuteAsync(IAppSession session, StringPackageInfo packa
                 .Select(p => int.Parse(p))
                 .Sum();
 
-            await session.SendAsync(Encoding.UTF8.GetBytes(result.ToString() + "\r\n"));
+            await session.SendAsync(Encoding.UTF8.GetBytes(result.ToString() + "\r\n"), cancellationToken);
         }
     }
 }
diff --git a/samples/CommandServer/MULT.cs b/samples/CommandServer/MULT.cs
@@ -19,7 +19,7 @@ public async ValueTask ExecuteAsync(IAppSession session, StringPackageInfo packa
                 .Select(p => int.Parse(p))
                 .Aggregate((x, y) => x * y);
 
-            await session.SendAsync(Encoding.UTF8.GetBytes(result.ToString() + "\r\n"));
+            await session.SendAsync(Encoding.UTF8.GetBytes(result.ToString() + "\r\n"), cancellationToken);
         }
     }
 }
diff --git a/samples/CommandServer/SUB.cs b/samples/CommandServer/SUB.cs
@@ -21,7 +21,7 @@ public async ValueTask ExecuteAsync(IAppSession session, StringPackageInfo packa
                 .Select(p => int.Parse(p))
                 .Aggregate((x, y) => x - y);
 
-            await session.SendAsync(Encoding.UTF8.GetBytes(result.ToString() + "\r\n"));
+            await session.SendAsync(Encoding.UTF8.GetBytes(result.ToString() + "\r\n"), cancellationToken);
         }
     }
 }
diff --git a/test/SuperSocket.Tests.Command/MIN.cs b/test/SuperSocket.Tests.Command/MIN.cs
@@ -17,7 +17,7 @@ public async ValueTask ExecuteAsync(IAppSession session, StringPackageInfo packa
             var result = package.Parameters
                 .Select(p => int.Parse(p)).OrderBy(x => x).FirstOrDefault();
 
-            await session.SendAsync(Encoding.UTF8.GetBytes(result.ToString() + "\r\n"));
+            await session.SendAsync(Encoding.UTF8.GetBytes(result.ToString() + "\r\n"), cancellationToken);
         }
     }
 }
diff --git a/test/SuperSocket.Tests.Command/SORT.cs b/test/SuperSocket.Tests.Command/SORT.cs
@@ -16,7 +16,7 @@ public async ValueTask ExecuteAsync(IAppSession session, StringPackageInfo packa
             var result = string.Join(' ', package.Parameters
                 .Select(p => int.Parse(p)).OrderBy(x => x).Select(x => x.ToString()));
 
-            await session.SendAsync(Encoding.UTF8.GetBytes($"{nameof(SORT)} {result}\r\n"));
+            await session.SendAsync(Encoding.UTF8.GetBytes($"{nameof(SORT)} {result}\r\n"), cancellationToken);
         }
     }
 }
diff --git a/test/SuperSocket.Tests/Commands.cs b/test/SuperSocket.Tests/Commands.cs
@@ -82,7 +82,7 @@ public async ValueTask ExecuteAsync(MySession session, StringPackageInfo package
 
             var socketSession = session as IAppSession;
             // encode the text message by encoder
-            await socketSession.SendAsync(_encoder, result.ToString() + "\r\n");
+            await socketSession.SendAsync(_encoder, result.ToString() + "\r\n", cancellationToken);
         }
     }
 
@@ -96,7 +96,7 @@ public class POW : JsonAsyncCommand<IAppSession, PowData>
     {
         protected override async ValueTask ExecuteJsonAsync(IAppSession session, PowData data, CancellationToken cancellationToken)
         {
-            await session.SendAsync(Encoding.UTF8.GetBytes($"{Math.Pow(data.X, data.Y)}\r\n"));
+            await session.SendAsync(Encoding.UTF8.GetBytes($"{Math.Pow(data.X, data.Y)}\r\n"), cancellationToken);
         }
     }
 
@@ -110,7 +110,7 @@ public class MAX : JsonAsyncCommand<IAppSession, MaxData>
         protected override async ValueTask ExecuteJsonAsync(IAppSession session, MaxData data, CancellationToken cancellationToken)
         {
             var maxValue = data.Numbers.OrderByDescending(i => i).FirstOrDefault();
-            await session.SendAsync(Encoding.UTF8.GetBytes($"{maxValue}\r\n"));
+            await session.SendAsync(Encoding.UTF8.GetBytes($"{maxValue}\r\n"), cancellationToken);
         }
     }
 }