From 718e8618544c4cdde78138655305eee7c08058ee Mon Sep 17 00:00:00 2001 From: Lizzy Fleckenstein Date: Sat, 18 Feb 2023 03:03:40 +0100 Subject: Don't spawn tasks --- src/client.rs | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) (limited to 'src/client.rs') diff --git a/src/client.rs b/src/client.rs index c4922ec..56db92a 100644 --- a/src/client.rs +++ b/src/client.rs @@ -19,7 +19,7 @@ impl UdpSender for ToSrv { #[async_trait] impl UdpReceiver for FromSrv { - async fn recv(&self) -> io::Result> { + async fn recv(&mut self) -> io::Result> { let mut buffer = Vec::new(); buffer.resize(UDP_PKT_SIZE, 0); @@ -30,7 +30,13 @@ impl UdpReceiver for FromSrv { } } -pub async fn connect(addr: &str) -> io::Result<(RudpSender, RudpReceiver)> { +pub struct RemoteSrv; +impl UdpPeer for RemoteSrv { + type Sender = ToSrv; + type Receiver = FromSrv; +} + +pub async fn connect(addr: &str) -> io::Result<(RudpSender, RudpReceiver)> { let sock = Arc::new(net::UdpSocket::bind("0.0.0.0:0").await?); sock.connect(addr).await?; -- cgit v1.2.3