diff --git a/quinn/src/connection.rs b/quinn/src/connection.rs index 64c306e91..c812609b8 100644 --- a/quinn/src/connection.rs +++ b/quinn/src/connection.rs @@ -966,6 +966,9 @@ impl State { // If the finishing stream was already dropped, there's nothing more to do. let _ = finishing.send(None); } + if let Some(stopped) = self.stopped.remove(&id) { + stopped.wake(); + } } Stream(StreamEvent::Stopped { id, error_code }) => { if let Some(stopped) = self.stopped.remove(&id) {