From 2a88ad0dd32b699ef71225bd19a8df8b0a6d1e7f Mon Sep 17 00:00:00 2001
From: Ning Sun <sunng@protonmail.com>
Date: Wed, 23 Oct 2024 16:51:32 -0700
Subject: [PATCH] chore: flush data in stream

---
 src/api/query.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/api/query.rs b/src/api/query.rs
index ef52083..a2ec636 100644
--- a/src/api/query.rs
+++ b/src/api/query.rs
@@ -420,7 +420,7 @@ where
     while let Some(row) = data_rows.next().await {
         let row = row?;
         rows += 1;
-        client.feed(PgWireBackendMessage::DataRow(row)).await?;
+        client.send(PgWireBackendMessage::DataRow(row)).await?;
     }
 
     let tag = Tag::new(&command_tag).with_rows(rows);