We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents deb8b1a + 7612ec9 commit cf3faf1Copy full SHA for cf3faf1
src/protocol/request_response/mod.rs
@@ -352,6 +352,9 @@ impl RequestResponseProtocol {
352
async fn on_connection_closed(&mut self, peer: PeerId) {
353
tracing::debug!(target: LOG_TARGET, ?peer, protocol = %self.protocol, "connection closed");
354
355
+ // Remove any pending outbound substreams for this peer.
356
+ self.pending_outbound.retain(|_, context| context.peer != peer);
357
+
358
let Some(context) = self.peers.remove(&peer) else {
359
tracing::error!(
360
target: LOG_TARGET,
0 commit comments