fixed the build

kerryjiang · Apr 18, 2024 · 6016a3f · 6016a3f
1 parent 4cea48c
commit 6016a3f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/samples/WebSocketPushServer/PushSession.cs b/samples/WebSocketPushServer/PushSession.cs
@@ -31,17 +31,17 @@ public int MessageClientReceived
 
         protected override async ValueTask OnSessionConnectedAsync()
         {
-            await this.SendAsync(this.SessionID);
+            await this.SendAsync(this.SessionID, CancellationToken.None);
         }
 
         public void Ack()
         {
             Interlocked.Increment(ref _messageClientReceived);
         }
 
-        public override async ValueTask SendAsync(string message)
+        public override async ValueTask SendAsync(string message, CancellationToken cancellationToken)
         {
-            await base.SendAsync(message);
+            await base.SendAsync(message, cancellationToken);
             Interlocked.Increment(ref _messageSent);
         }
 

diff --git a/samples/WebSocketPushServer/ServerPushMiddleware.cs b/samples/WebSocketPushServer/ServerPushMiddleware.cs
@@ -59,7 +59,7 @@ private async ValueTask<int> Push()
 
             foreach (var s in _sessionContainer.GetSessions<PushSession>())
             {
-                await s.SendAsync(line);
+                await s.SendAsync(line, CancellationToken.None);
                 count++;
 
                 if (_stopped)