Skip to content
This repository was archived by the owner on Jan 14, 2025. It is now read-only.

Commit 9913ef3

Browse files
authored
Testing the removal of a close (#8)
* test this * fix: match ready for query in start
1 parent 99908ea commit 9913ef3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

tokio-postgres/src/query.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ where
110110
frontend::sync(buf);
111111

112112
// Close
113-
frontend::close(b'S', "", buf).map_err(Error::encode)?;
113+
// frontend::close(b'S', "", buf).map_err(Error::encode)?;
114114

115115
Ok(buf.split().freeze())
116116
})?;
@@ -212,7 +212,7 @@ async fn start(client: &InnerClient, buf: Bytes) -> Result<(Option<Statement>, R
212212

213213
loop {
214214
match responses.next().await? {
215-
Message::CloseComplete | Message::ParseComplete => {}
215+
Message::CloseComplete | Message::ParseComplete | Message::ReadyForQuery(_) => {}
216216
Message::BindComplete => return Ok((statement, responses)),
217217
Message::ParameterDescription(body) => {
218218
parameter_description = Some(body); // tooo-o-ooo-o loooove

0 commit comments

Comments
 (0)