diff options
| author | littleblack111 <littleblack11111@gmail.com> | 2025-10-21 22:23:52 +0800 |
|---|---|---|
| committer | littleblack111 <littleblack11111@gmail.com> | 2025-10-21 22:48:29 +0800 |
| commit | db71798db2ba7ede27f2ad7f2428cffbf8f1e98c (patch) | |
| tree | e6e2895b6f6d59dff5759ae6f54144e5328411ec /src/network.rs | |
| parent | a2d6e450fd488cb737474f0ff9810c2d1f9108cf (diff) | |
feat: peer cmd
refactor: Ui now takes network
Diffstat (limited to 'src/network.rs')
| -rw-r--r-- | src/network.rs | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/network.rs b/src/network.rs index 181bb2c..72f47e7 100644 --- a/src/network.rs +++ b/src/network.rs @@ -4,6 +4,7 @@ use serde::{Deserialize, Serialize}; use futures::stream::{SplitSink, SplitStream}; use futures::{SinkExt, StreamExt}; +use tokio::net::ToSocketAddrs; use tokio::{ net::{TcpListener, TcpStream}, spawn, @@ -72,8 +73,8 @@ impl Network { this } - async fn try_peer(this: Weak<Mutex<Self>>) { - let stream = TcpStream::connect("192.168.1.16:6767") + pub async fn try_peer(this: Weak<Mutex<Self>>, ip: impl ToSocketAddrs) { + let stream = TcpStream::connect(ip) .await .unwrap(); let peer = Arc::new(Mutex::new(Peer::new(this.clone(), stream))); @@ -132,7 +133,7 @@ impl Network { .this .clone(); spawn(async move { - Network::try_peer(this).await; + Network::try_peer(this, "192.168.1.16:6767").await; }); self.get_idb() |
