fix(stream): Fix another problem in read_message

Previously, we'd loop forever if there wasn't enough data for decode.

pgproto/src/stream.rs

@@ -69,18 +69,18 @@ impl<S: io::Read> PgStream<S> {
     /// Receive a new message from client.
     pub fn read_message(&mut self) -> PgWireResult<FeMessage> {
         loop {
-            if self.ibuf.is_empty() {
-                let cnt = read_into_buf(&mut self.raw, &mut self.ibuf)?;
-                log::debug!("received {cnt} bytes from client");
-                assert!(
-                    cnt > 0,
-                    "TODO: check if coio wrapper returns 0 or EOF error"
-                );
+            if !self.ibuf.is_empty() {
+                if let Some(message) = self.try_decode_message()? {
+                    return Ok(message);
+                }
             }
 
-            if let Some(message) = self.try_decode_message()? {
-                return Ok(message);
-            }
+            let cnt = read_into_buf(&mut self.raw, &mut self.ibuf)?;
+            log::info!("received {cnt} bytes from client");
+            assert!(
+                cnt > 0,
+                "TODO: check if coio wrapper returns 0 or EOF error"
+            );
         }
     }
 }