Contents in _packagePipe are not read after the socket is disconnecte…

…d. (#657)
kerryjiang · Jun 1, 2023 · 86263bc · 86263bc
1 parent 305b19a
commit 86263bc
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/SuperSocket.Channel/PipeChannel.cs b/src/SuperSocket.Channel/PipeChannel.cs
@@ -84,7 +84,7 @@ public async override IAsyncEnumerable<TPackageInfo> RunAsync()
             if (_readsTask == null || _sendsTask == null)
                 throw new Exception("The channel has not been started yet.");
 
-            while (true)
+            while (!_cts.IsCancellationRequested)
             {
                 var package = await _packagePipe.ReadAsync().ConfigureAwait(false);
 
@@ -95,6 +95,8 @@ public async override IAsyncEnumerable<TPackageInfo> RunAsync()
 
                 yield return package;
             }
+
+            //How do empty a pipe?
         }
 
         private async ValueTask HandleClosing()