aboutsummaryrefslogtreecommitdiff
path: root/src/new.rs
diff options
context:
space:
mode:
Diffstat (limited to 'src/new.rs')
-rw-r--r--src/new.rs9
1 files changed, 7 insertions, 2 deletions
diff --git a/src/new.rs b/src/new.rs
index 9f820a9..b17f518 100644
--- 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;
});