diff --git a/sqlx-core/src/postgres/executor.rs b/sqlx-core/src/postgres/executor.rs
index 41fc40b2..61fe4ba8 100644
--- a/sqlx-core/src/postgres/executor.rs
+++ b/sqlx-core/src/postgres/executor.rs
@@ -167,7 +167,7 @@ impl PgConnection {
             if !self.cache_statement_id.contains_key(query) {
                 // wait for `ParseComplete` on the stream or the
                 // error before we cache the statement
-                match self.stream.read().await? {
+                match self.stream.receive().await? {
                     Message::ParseComplete => {
                         self.cache_statement_id.insert(query.into(), statement);
                     }