Merge pull request #973 from penberg/flush

Add flush() to front-end messages
2022-12-30 08:33:07 -05:00 · 2022-12-30 08:33:07 -05:00 · 9774c330f1
commit 9774c330f1
parent 97db777078 d368475b50
1 changed files with 6 additions and 0 deletions
--- a/postgres-protocol/src/message/frontend.rs
+++ b/postgres-protocol/src/message/frontend.rs
@ -271,6 +271,12 @@ where
    })
 }

+#[inline]
+pub fn flush(buf: &mut BytesMut) {
+    buf.put_u8(b'H');
+    write_body(buf, |_| Ok::<(), io::Error>(())).unwrap();
+}
+
 #[inline]
 pub fn sync(buf: &mut BytesMut) {
    buf.put_u8(b'S');