Fix directly mqtt for mqtt-ws-server.rs

ntex-rs · Feb 24, 2025 · 8ffe291 · 8ffe291
1 parent faa0d47
commit 8ffe291
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/examples/mqtt-ws-server.rs b/examples/mqtt-ws-server.rs
@@ -122,9 +122,9 @@ async fn main() -> std::io::Result<()> {
                     loop {
                         // we can read incoming bytes stream without consuming it
                         let result = io.with_read_buf(|buf| {
-                            if buf.len() < 4 {
+                            if buf.len() < 8 {
                                 None
-                            } else if &buf[..4] == b"MQTT" {
+                            } else if &buf[4..8] == b"MQTT" {
                                 println!("MQTT protocol is selected");
                                 Some(Protocol::Mqtt)
                             } else if &buf[..4] == b"GET " {