fix: flush byte is not covered in decode

sunng87 · Sep 26, 2023 · eb82b88 · eb82b88
1 parent f7f1b0a
commit eb82b88
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))
                 }