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 {