fix test

CHANGES.md

@@ -8,7 +8,9 @@
 
 * Remove protocol variant services
 
-* Disable keep-alive timer is not configured
+* Disable keep-alive timer if not configured
+
+* Add write back-pressure to io dispatcher
 
 ## [1.1.0] - 2024-03-07
 

src/io.rs

@@ -1051,7 +1051,6 @@ mod tests {
     /// Do not use keep-alive timer if not configured
     #[ntex::test]
     async fn test_no_keepalive_err_after_frame_timeout() {
-        env_logger::init();
         let (client, server) = Io::create();
         client.remote_buffer_cap(1024);
 

src/v3/dispatcher.rs

@@ -411,12 +411,11 @@ where
                         inner.inflight.borrow_mut().remove(&res.packet_id);
                         Some(codec::Packet::UnsubscribeAck { packet_id: res.packet_id })
                     }
-                    ControlAckKind::Disconnect
-                    | ControlAckKind::Closed
-                    | ControlAckKind::Nothing => {
+                    ControlAckKind::Disconnect => {
                         inner.sink.close();
                         None
                     }
+                    ControlAckKind::Closed | ControlAckKind::Nothing => None,
                     ControlAckKind::PublishAck(_) => unreachable!(),
                 };
                 return Ok(packet);