Flushing a closed stream is okay

thomaseizinger · thomaseizinger · commit 6c03282f8612 · 2023-05-19T18:42:02.000+02:00
diff --git a/yamux/src/connection/stream.rs b/yamux/src/connection/stream.rs
@@ -363,6 +363,10 @@ impl AsyncWrite for Stream {
     }
 
     fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<io::Result<()>> {
+        if self.is_closed() {
+            return Poll::Ready(Ok(()));
+        }
+
         let num_frames = {
             let shared = self.shared();
 

Original file line number	Diff line number	Diff line change
`@@ -363,6 +363,10 @@ impl AsyncWrite for Stream {`
`363`	`363`	`}`
`364`	`364`
`365`	`365`	`fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context) -> Poll<io::Result<()>> {`
	`366`	`+ if self.is_closed() {`
	`367`	`+ return Poll::Ready(Ok(()));`
	`368`	`+ }`
	`369`	`+`
`366`	`370`	`let num_frames = {`
`367`	`371`	`let shared = self.shared();`
`368`	`372`