cleanup; readme

[mt_rudp.git] / src / new.rs

diff --git a/src/new.rs b/src/new.rs
index 9f820a9f8536d61beb1315aecfeb38de9bca13bf..b17f518f2bf87138eada268efdebe3717af12401 100644 (file)
--- a/src/new.rs
+++ b/src/new.rs
@@ -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;
         });