aboutsummaryrefslogtreecommitdiff
path: root/src/new.rs
diff options
context:
space:
mode:
authorLizzy Fleckenstein <eliasfleckenstein@web.de>2023-01-06 21:20:09 +0100
committerLizzy Fleckenstein <eliasfleckenstein@web.de>2023-01-06 21:20:15 +0100
commit9ee7b7ddc5c3611bf515dbdee4134b6df9efed92 (patch)
tree09247c8cf80c19e1e005d3be8b03b97a30aaa6b4 /src/new.rs
parent12bfebc06ed29fabbc4a4357e314b8fbde1b552d (diff)
downloadmt_rudp-9ee7b7ddc5c3611bf515dbdee4134b6df9efed92.tar.xz
cleanup; readme
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;
});