fix(postgres): avoid unnecessary flush in PgCopyIn::read_from

launchbadge · Dec 12, 2023 · 91c6e66 · 91c6e66
1 parent 929af41
commit 91c6e66
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();