Merge pull request #113 from elmaxxo/elmaxxo/fix/flush-byte-is-not-co…

…vered-in-decode fix: flush byte is not covered in decode
sunng87 · Sep 27, 2023 · a3d820d · a3d820d
2 parents f7f1b0a + eb82b88
commit a3d820d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/messages/mod.rs b/src/messages/mod.rs
@@ -147,6 +147,9 @@ impl PgWireFrontendMessage {
                 extendedquery::MESSAGE_TYPE_BYTE_EXECUTE => {
                     extendedquery::Execute::decode(buf).map(|v| v.map(Self::Execute))
                 }
+                extendedquery::MESSAGE_TYPE_BYTE_FLUSH => {
+                    extendedquery::Flush::decode(buf).map(|v| v.map(Self::Flush))
+                }
                 extendedquery::MESSAGE_TYPE_BYTE_SYNC => {
                     extendedquery::Sync::decode(buf).map(|v| v.map(Self::Sync))
                 }