diff options
author | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-01-06 21:20:09 +0100 |
---|---|---|
committer | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-01-06 21:20:15 +0100 |
commit | 9ee7b7ddc5c3611bf515dbdee4134b6df9efed92 (patch) | |
tree | 09247c8cf80c19e1e005d3be8b03b97a30aaa6b4 /src/new.rs | |
parent | 12bfebc06ed29fabbc4a4357e314b8fbde1b552d (diff) | |
download | mt_rudp-9ee7b7ddc5c3611bf515dbdee4134b6df9efed92.tar.xz |
cleanup; readme
Diffstat (limited to 'src/new.rs')
-rw-r--r-- | src/new.rs | 9 |
1 files changed, 7 insertions, 2 deletions
@@ -1,4 +1,9 @@ -use crate::*; +use crate::{prelude::*, ticker, Chan, RecvWorker, RudpShare}; +use std::{collections::HashMap, io, sync::Arc, time::Duration}; +use tokio::{ + sync::{mpsc, watch, Mutex, RwLock}, + task::JoinSet, +}; pub async fn new<S: UdpSender, R: UdpReceiver>( id: u16, @@ -33,7 +38,7 @@ pub async fn new<S: UdpSender, R: UdpReceiver>( /*.build_task() .name("recv")*/ .spawn(async move { - let worker = recv::RecvWorker::new(udp_rx, recv_share, recv_close, pkt_tx); + let worker = RecvWorker::new(udp_rx, recv_share, recv_close, pkt_tx); worker.run().await; }); |