Merge pull request #2932 from tsing/fix-copy-in

fix(postgres): avoid unnecessary flush in PgCopyIn::read_from
launchbadge · Jan 6, 2024 · ea4703e · ea4703e
2 parents 2d397a5 + 91c6e66
commit ea4703e
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/sqlx-postgres/src/copy.rs b/sqlx-postgres/src/copy.rs
@@ -221,10 +221,6 @@ impl<C: DerefMut<Target = PgConnection>> PgCopyIn<C> {
         }
 
         let conn: &mut PgConnection = self.conn.as_deref_mut().expect("copy_from: conn taken");
-
-        // flush any existing messages in the buffer and clear it
-        conn.stream.flush().await?;
-
         loop {
             let buf = conn.stream.write_buffer_mut();