chore: flush data in stream

sunng87 · Oct 23, 2024 · 2a88ad0 · 2a88ad0
1 parent d1d64c6
commit 2a88ad0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);