mirror/Easytier
1
0
Fork 0
mirror of https://github.com/EasyTier/EasyTier.git synced 2026-08-05 20:19:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

style: format noop waker mpsc tests

Browse Source
This commit is contained in:
fanyang
2026-06-30 21:23:46 +08:00
parent cb35c17503
commit 3de3fabcbc
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
easytier/src/tunnel/mpsc.rs
+4 -2
View File
@@ -303,7 +303,8 @@ mod tests {
for i in 0..1000000 { for i in 0..1000000 {
tokio::time::sleep(tokio::time::Duration::from_millis(50)).await; tokio::time::sleep(tokio::time::Duration::from_millis(50)).await;
let a = sink1 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() { if a.is_err() {
tracing::info!(?a, "t2 exit with err"); tracing::info!(?a, "t2 exit with err");
break; break;
@@ -322,7 +323,8 @@ mod tests {
for i in 0..1000000 { for i in 0..1000000 {
tokio::time::sleep(tokio::time::Duration::from_millis(100)).await; tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
let a = sink2 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() { if a.is_err() {
tracing::info!(?a, "t3 exit with err"); tracing::info!(?a, "t3 exit with err");
break; break;