summaryrefslogtreecommitdiffstats
path: root/mqtt-tester
diff options
context:
space:
mode:
authorMatthias Beyer <mail@beyermatthias.de>2023-01-17 09:47:19 +0100
committerMatthias Beyer <mail@beyermatthias.de>2023-01-19 12:51:50 +0100
commitcd223536fec0dce5636f054c4ca835b604836bf4 (patch)
treeccc1ea5653c5f4896a88c4d898f43cc2640f0aa1 /mqtt-tester
parentbc4c59135ec420dcf1b21bdf942d5ad01cc5cfe6 (diff)
Fix: Remove read
This read was a bug. We only need to read two bytes and then decide what to do, not three. Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
Diffstat (limited to 'mqtt-tester')
-rw-r--r--mqtt-tester/src/command.rs1
1 files changed, 0 insertions, 1 deletions
diff --git a/mqtt-tester/src/command.rs b/mqtt-tester/src/command.rs
index 8e36b46..bb67a7f 100644
--- a/mqtt-tester/src/command.rs
+++ b/mqtt-tester/src/command.rs
@@ -97,7 +97,6 @@ impl Output {
match tokio::time::timeout(std::time::Duration::from_millis(100), async {
let mut buffer = BytesMut::new();
buffer.put_u16(self.stdout.read_u16().await.into_diagnostic()?);
- buffer.put_u8(self.stdout.read_u8().await.into_diagnostic()?);
if buffer[1] & 0b1000_0000 != 0 {
buffer.put_u8(self.stdout.read_u8().await.into_diagnostic()?);