From 5ffe2d59b70f1654cf27273bacfbbeedd7034960 Mon Sep 17 00:00:00 2001
From: Igor Katson <igor.katson@gmail.com>
Date: Fri, 26 Apr 2024 09:30:26 +0100
Subject: [PATCH] Fix streaming logic

---
 crates/librqbit/src/torrent_state/live/mod.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/crates/librqbit/src/torrent_state/live/mod.rs b/crates/librqbit/src/torrent_state/live/mod.rs
index 35f2f2d..cc0b51e 100644
--- a/crates/librqbit/src/torrent_state/live/mod.rs
+++ b/crates/librqbit/src/torrent_state/live/mod.rs
@@ -984,7 +984,7 @@ impl PeerHandler {
                         .iter_next_pieces(&self.state.lengths)
                         .filter(|pid| {
                             !chunk_tracker.is_piece_have(*pid)
-                                && chunk_tracker.is_piece_queued(*pid)
+                                && !g.inflight_pieces.contains_key(pid)
                         });
                     let natural_order_pieces =
                         chunk_tracker.iter_queued_pieces(&g.file_priorities, &self.state.files);