From af326f687032830efe777197fd33d60d34edf09c Mon Sep 17 00:00:00 2001
From: hatoo <hato2000@gmail.com>
Date: Wed, 27 Nov 2024 20:09:32 +0900
Subject: [PATCH] Avoid tx.send() blocking on work_until_with_qps

I made it unbounded, because bounded channel donsn't make things better any
sense
---
 src/client.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/client.rs b/src/client.rs
index 0f7e3460..84819353 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -1401,7 +1401,7 @@ pub async fn work_until_with_qps(
 ) {
     let rx = match query_limit {
         QueryLimit::Qps(qps) => {
-            let (tx, rx) = flume::bounded(qps);
+            let (tx, rx) = flume::unbounded();
             tokio::spawn(async move {
                 for i in 0.. {
                     if std::time::Instant::now() > dead_line {