Works pretty well now!

crates/librqbit/src/torrent_state/live/mod.rs

@@ -740,11 +740,11 @@ impl TorrentStateLive {
     }
 
     pub(crate) fn reconnect_all_not_needed_peers(&self) {
-        for pe in self.peers.states.iter() {
+        for mut pe in self.peers.states.iter_mut() {
-            if let PeerState::NotNeeded = pe.value().state.get() {
+            if pe.state.not_needed_to_queued(&self.peers.stats)
-                if self.peer_queue_tx.send(*pe.key()).is_err() {
+                && self.peer_queue_tx.send(*pe.key()).is_err()
-                    return;
+            {
-                }
+                return;
             }
         }
     }

crates/librqbit/src/torrent_state/live/peer/mod.rs

@@ -123,6 +123,14 @@ impl PeerStateNoMut {
         }
     }
 
+    pub fn not_needed_to_queued(&mut self, counters: &AggregatePeerStatsAtomic) -> bool {
+        if let PeerState::NotNeeded = &self.0 {
+            self.set(PeerState::Queued, counters);
+            return true;
+        }
+        false
+    }
+
     pub fn incoming_connection(
         &mut self,
         peer_id: Id20,