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;