wip

ntex-rs · Apr 15, 2024 · 8ca69fa · 8ca69fa
1 parent bf8d53d
commit 8ca69fa
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/tests/test_server.rs b/tests/test_server.rs
@@ -449,7 +449,7 @@ async fn handle_or_drop_publish_after_disconnect(
  .unwrap();
  io.encode(codec::Packet::Disconnect, &codec).unwrap();
  io.flush(true).await.unwrap();
- io.force_close();
+ io.close();
  drop(io);
  sleep(Millis(250)).await;
 

diff --git a/tests/test_server_v5.rs b/tests/test_server_v5.rs
@@ -1006,6 +1006,8 @@ async fn handle_or_drop_publish_after_disconnect(
  max_qos: QoS,
  handle_qos_after_disconnect: Option<QoS>,
 ) -> bool {
+ let _ = env_logger::try_init();
+
  let publish = Arc::new(AtomicBool::new(false));
  let publish2 = publish.clone();
  let disconnect = Arc::new(AtomicBool::new(false));
@@ -1070,9 +1072,9 @@ async fn handle_or_drop_publish_after_disconnect(
  )
  .unwrap();
  io.flush(true).await.unwrap();
+ io.close();
  drop(io);
-
- sleep(Millis(50)).await;
+ sleep(Millis(250)).await;
 
  assert!(disconnect.load(Relaxed));