Fix missing wakeups on large stream credit increase

This commit is contained in:
Benjamin Saunders
2022-09-18 09:43:58 -07:00
committed by Dirkjan Ochtman
parent 49b2620132
commit 5fa3581edb
+2 -1
View File
@@ -930,7 +930,8 @@ impl ConnectionInner {
}
}
Stream(StreamEvent::Available { dir }) => {
self.stream_opening[dir as usize].notify_one();
// Might mean any number of streams are ready, so we wake up everyone
self.stream_opening[dir as usize].notify_waiters();
}
Stream(StreamEvent::Finished { id }) => {
if let Some(finishing) = self.finishing.remove(&id) {