pgdog.git / summary / log / commit / refs

commit    cd6e720e930f929f6b0d015c8fa44f3ca1c115da
Author:   Lev Kokotov <levkk@users.noreply.github.com>
Commit:   GitHub <noreply@github.com>
Date:     Thu Sep 11 04:11:32 2025 +0000

    flush fix (#442)


 pgdog/src/frontend/client_request.rs | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/pgdog/src/frontend/client_request.rs b/pgdog/src/frontend/client_request.rs
index c155d98f..c6bd4735 100644
--- a/pgdog/src/frontend/client_request.rs
+++ b/pgdog/src/frontend/client_request.rs
@@ -185,7 +185,7 @@ impl ClientRequest {
         for message in &self.messages {
             let code = message.code();
             match code {
-                'P' | 'B' | 'D' | 'C' => {
+                'P' | 'B' | 'D' | 'C' | 'H' => {
                     req.messages.push(message.clone());
                 }
 
@@ -270,5 +270,13 @@ mod test {
         let req = ClientRequest::from(messages);
         let splice = req.splice().unwrap();
         assert!(splice.is_empty());
+
+        let messages = vec![
+            ProtocolMessage::from(Parse::named("test", "SELECT 1")),
+            Flush.into(),
+        ];
+        let req = ClientRequest::from(messages);
+        let splice = req.splice().unwrap();
+        assert!(splice.is_empty());
     }
 }


[parent: db36b7904635]