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);