From 715b77323d22044bf4dd75dfd069edd7198a7036 Mon Sep 17 00:00:00 2001
From: littleblack111 <littleblack11111@gmail.com>
Date: Tue, 21 Oct 2025 22:35:30 +0800
Subject: refactor(network): direct write function, which broadcast uses now

feat(cmd): fetch to refresh idb
---
 src/network.rs | 27 +++++++++++++++++----------
 1 file changed, 17 insertions(+), 10 deletions(-)

(limited to 'src/network.rs')

diff --git a/src/network.rs b/src/network.rs
index 72f47e7..1a08053 100644
--- a/src/network.rs
+++ b/src/network.rs
@@ -160,20 +160,27 @@ impl Network {
                 .clone()
         };
         for p in peers {
-            let sink = {
-                let peer = p
-                    .lock()
-                    .await;
-                Arc::clone(&peer.sink)
-            };
-            let mut sink = sink
+            p.lock()
+                .await
+                .sink
                 .lock()
-                .await;
-            let _ = sink
+                .await
                 .send(data.clone())
-                .await;
+                .await
+                .unwrap();
         }
     }
+
+    async fn write(peer: &mut Peer, data: Request) -> Result<(), std::io::Error> {
+        let sink = peer
+            .sink
+            .clone();
+        let mut sink = sink
+            .lock()
+            .await;
+        sink.send(data.clone())
+            .await
+    }
 }
 
 struct Peer {
-- 
cgit v1.2.3