diff options
| author | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2022-12-28 23:30:02 +0100 |
|---|---|---|
| committer | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2022-12-28 23:30:02 +0100 |
| commit | f160c0fa78744b337f03b619e2d8b61ed916402b (patch) | |
| tree | 92367a3bffd313fa754cc104b2f98c0f91a4abc4 /src/recv_worker.rs | |
| parent | 976be3aa3b50ef7721fce2d38ed5855ed64a719a (diff) | |
| download | mt_rudp-f160c0fa78744b337f03b619e2d8b61ed916402b.tar.xz | |
fix async
Diffstat (limited to 'src/recv_worker.rs')
| -rw-r--r-- | src/recv_worker.rs | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/src/recv_worker.rs b/src/recv_worker.rs index 60cadeb..5a156eb 100644 --- a/src/recv_worker.rs +++ b/src/recv_worker.rs @@ -34,7 +34,7 @@ pub struct RecvWorker<R: UdpReceiver, S: UdpSender> { } impl<R: UdpReceiver, S: UdpSender> RecvWorker<R, S> { - pub async fn new(udp_rx: R, share: Arc<RudpShare<S>>, pkt_tx: mpsc::UnboundedSender<InPkt>) { + pub fn new(udp_rx: R, share: Arc<RudpShare<S>>, pkt_tx: mpsc::UnboundedSender<InPkt>) -> Self { Self { udp_rx, share, @@ -52,8 +52,6 @@ impl<R: UdpReceiver, S: UdpSender> RecvWorker<R, S> { .collect(), ), } - .run() - .await } pub async fn run(&self) { |