fix

cloudwego · Jan 9, 2024 · 8819746 · 8819746
1 parent bc8f85e
commit 8819746
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/volo-thrift/src/transport/multiplex/thrift_transport.rs b/volo-thrift/src/transport/multiplex/thrift_transport.rs
@@ -91,7 +91,7 @@ where
                     write_half.reset().await;
                     has_error = false;
                     let mut queue = batch_queu.lock().await;
-                    if queue.is_empty()
+                    while queue.is_empty()
                         && !inner_read_error.load(std::sync::atomic::Ordering::Relaxed)
                         && !inner_read_closed.load(std::sync::atomic::Ordering::Relaxed)
                     {