fix queue tests

Co-authored-by: Arya <aryasolhi@gmail.com>

zebra-rpc/src/methods/tests/prop.rs

@@ -605,8 +605,10 @@ proptest! {
             let transaction_hash = tx.hash();
             let tx_bytes = tx.zcash_serialize_to_vec()?;
             let tx_hex = hex::encode(&tx_bytes);
-            let send_task = tokio::task::spawn(async move { rpc.send_raw_transaction(tx_hex).await });
-
+            let send_task = {
+                let rpc = rpc.clone();
+                tokio::task::spawn(async move { rpc.send_raw_transaction(tx_hex).await })
+            };
             let tx_unmined = UnminedTx::from(tx);
             let expected_request = mempool::Request::Queue(vec![tx_unmined.clone().into()]);
 

zebra-rpc/src/queue.rs

@@ -180,9 +180,6 @@ impl Runner {
                 };
 
                 self.queue.insert(tx.clone());
-                if self.receiver.is_empty() {
-                    break;
-                }
             }
 
             // skip some work if stored tip height is the same as the one arriving