CancelPendingRead for output pipe

kerryjiang · Jan 1, 2025 · 7305207 · 7305207
1 parent ac1a78c
commit 7305207
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/src/SuperSocket.Connection/PipeConnection.cs b/src/SuperSocket.Connection/PipeConnection.cs
@@ -205,5 +205,10 @@ protected override bool IsIgnorableException(Exception e)
 
             return false;
         }
+
+        protected override void CancelOutputPendingRead()
+        {
+            this.Output.Reader.CancelPendingRead();
+        }
     }
 }
diff --git a/src/SuperSocket.Connection/PipeConnectionBase.cs b/src/SuperSocket.Connection/PipeConnectionBase.cs
@@ -147,6 +147,7 @@ protected async Task CancelAsync()
 
             _cts.Cancel();
             await CompleteWriterAsync(OutputWriter, _isDetaching).ConfigureAwait(false);
+            CancelOutputPendingRead();
         }
 
         protected virtual bool IsIgnorableException(Exception e)
@@ -438,5 +439,9 @@ protected virtual async ValueTask CompleteWriterAsync(PipeWriter writer, bool is
         {
             await writer.CompleteAsync().ConfigureAwait(false);
         }
+
+        protected virtual void CancelOutputPendingRead()
+        {
+        }
     }
 }