Do not process data in read buffer after disconnect

CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [0.12.9] - 2023-11-17
+
+* Do not process data in read buffer after disconnect
+
 ## [0.12.8] - 2023-11-12
 
 * Use new ntex-io apis

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-mqtt"
-version = "0.12.8"
+version = "0.12.9"
 authors = ["ntex contributors <[email protected]>"]
 description = "Client and Server framework for MQTT v5 and v3.1.1 protocols"
 documentation = "https://docs.rs/ntex-mqtt"
@@ -26,7 +26,7 @@ thiserror = "1.0"
 
 [dev-dependencies]
 env_logger = "0.10"
-ntex-tls = "0.3.1"
+ntex-tls = "0.3"
 rustls = "0.21"
 rustls-pemfile = "1.0"
 openssl = "0.10"

src/io.rs

@@ -253,6 +253,12 @@ where
                 IoDispatcherState::Processing => {
                     let item = match ready!(inner.poll_service(this.service, cx)) {
                         PollService::Ready => {
+                            if inner.io.is_closed() {
+                                log::trace!("io has been closed, stop dispatcher");
+                                inner.st = IoDispatcherState::Stop;
+                                continue;
+                            }
+
                             // decode incoming bytes stream
                             match inner.io.poll_recv_decode(this.codec, cx) {
                                 Ok(decoded) => {