diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/transport/libp2p.rs | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/transport/libp2p.rs b/src/transport/libp2p.rs index 75792c5..b9f54a9 100644 --- a/src/transport/libp2p.rs +++ b/src/transport/libp2p.rs @@ -1987,13 +1987,12 @@ async fn run( } if let Some(peer) = peer_id && !swarm.is_connected(&peer) + && let Some(waiting) = connecting.remove(&peer) { - if let Some(waiting) = connecting.remove(&peer) { - for done in waiting { - let _ = done.send(Err(describe_dial_error(&error))); - } - find_on_dht(&mut swarm, peer); + for done in waiting { + let _ = done.send(Err(describe_dial_error(&error))); } + find_on_dht(&mut swarm, peer); } } SwarmEvent::NewListenAddr { address, .. } => { |