From 3de3fabcbc461d63eb121f0ba07b0fc9cafaccbe Mon Sep 17 00:00:00 2001 From: fanyang Date: Tue, 30 Jun 2026 21:23:46 +0800 Subject: [PATCH] style: format noop waker mpsc tests --- easytier/src/tunnel/mpsc.rs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/easytier/src/tunnel/mpsc.rs b/easytier/src/tunnel/mpsc.rs index 663b7dc5..2e9962ba 100644 --- a/easytier/src/tunnel/mpsc.rs +++ b/easytier/src/tunnel/mpsc.rs @@ -303,7 +303,8 @@ mod tests { for i in 0..1000000 { tokio::time::sleep(tokio::time::Duration::from_millis(50)).await; let a = sink1 - .send_async(ZCPacket::new_with_payload("hello".as_bytes())).await; + .send_async(ZCPacket::new_with_payload("hello".as_bytes())) + .await; if a.is_err() { tracing::info!(?a, "t2 exit with err"); break; @@ -322,7 +323,8 @@ mod tests { for i in 0..1000000 { tokio::time::sleep(tokio::time::Duration::from_millis(100)).await; let a = sink2 - .send_async(ZCPacket::new_with_payload("hello2".as_bytes())).await; + .send_async(ZCPacket::new_with_payload("hello2".as_bytes())) + .await; if a.is_err() { tracing::info!(?a, "t3 exit with err"); break;