We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d348970 commit 0daed49Copy full SHA for 0daed49
client/network/src/protocol/generic_proto/handler.rs
@@ -684,6 +684,7 @@ impl ProtocolsHandler for NotifsHandler {
684
_ => unreachable!()
685
};
686
687
+ debug_assert_eq!(pending_opening.len(), self.out_protocols.len());
688
for (n, is_pending) in pending_opening.iter().enumerate() {
689
if *is_pending {
690
continue;
@@ -740,8 +741,9 @@ impl ProtocolsHandler for NotifsHandler {
740
741
742
match &mut self.state {
743
State::Open { .. } => {
744
+ let pending_opening = self.out_protocols.iter().map(|_| false).collect();
745
self.state = State::Closed {
- pending_opening: Vec::new(),
746
+ pending_opening,
747
748
},
749
State::Opening { out_substreams, .. } => {
0 commit comments