diff options
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; }); |