Contents in _packagePipe are not read after the socket is disconnected. (#657)

wj8400684 · web-flow · commit 86263bcb986e · 2023-05-31T21:02:06.000-07:00
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()

Original file line number	Diff line number	Diff line change
`@@ -84,7 +84,7 @@ public async override IAsyncEnumerable<TPackageInfo> RunAsync()`
`84`	`84`	`if (_readsTask == null \|\| _sendsTask == null)`
`85`	`85`	`throw new Exception("The channel has not been started yet.");`
`86`	`86`
`87`		`- while (true)`
	`87`	`+ while (!_cts.IsCancellationRequested)`
`88`	`88`	`{`
`89`	`89`	`var package = await _packagePipe.ReadAsync().ConfigureAwait(false);`
`90`	`90`
`@@ -95,6 +95,8 @@ public async override IAsyncEnumerable<TPackageInfo> RunAsync()`
`95`	`95`
`96`	`96`	`yield return package;`
`97`	`97`	`}`
	`98`	`+`
	`99`	`+ //How do empty a pipe?`
`98`	`100`	`}`
`99`	`101`
`100`	`102`	`private async ValueTask HandleClosing()`