diff --git a/src/message_read.rs b/src/message_read.rs index 4e13313..8fb8719 100644 --- a/src/message_read.rs +++ b/src/message_read.rs @@ -22,7 +22,7 @@ impl MessageReader { } fn parse_first(&mut self) -> anyhow::Result { - let length = u16::from_be_bytes([self.buffer[0], self.buffer[2]]); + let length = u16::from_be_bytes([self.buffer[0], self.buffer[1]]); let message_length = 2 + length as usize; let message = self.buffer[..message_length].to_vec(); self.buffer = self.buffer[message_length..].to_vec();