aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/network.rs
diff options
context:
space:
mode:
authorEskil Queseth <eskilq@kth.se>2021-02-03 01:26:02 +0100
committerEskil Queseth <eskilq@kth.se>2021-02-03 01:26:02 +0100
commiteb96b559680e42173c0571b65fcb7fb63afbab62 (patch)
tree59ed522612fbd16a2aa6541e9cd785f78d691925 /mumd/src/network.rs
parent154a2930b3bbe5ede06648c3a10b8fa4904277f4 (diff)
downloadmum-eb96b559680e42173c0571b65fcb7fb63afbab62.tar.gz
clean up depending on futures
Diffstat (limited to 'mumd/src/network.rs')
-rw-r--r--mumd/src/network.rs15
1 files changed, 5 insertions, 10 deletions
diff --git a/mumd/src/network.rs b/mumd/src/network.rs
index 6c67b3a..7950dc7 100644
--- a/mumd/src/network.rs
+++ b/mumd/src/network.rs
@@ -1,15 +1,10 @@
pub mod tcp;
pub mod udp;
-use futures::Future;
-use futures::FutureExt;
-use futures::channel::oneshot;
-use futures::join;
-use futures::pin_mut;
-use futures::select;
+use futures_util::FutureExt;
use log::*;
-use std::net::SocketAddr;
-use tokio::sync::watch;
+use std::{future::Future, net::SocketAddr};
+use tokio::{join, select, sync::{oneshot, watch}};
use crate::state::StatePhase;
@@ -58,9 +53,9 @@ async fn run_until<F>(
let main_block = async {
let rx = rx.fuse();
- pin_mut!(rx);
+ //pin_mut!(rx);
let fut = fut.fuse();
- pin_mut!(fut);
+ //pin_mut!(fut);
select! {
_ = fut => (),
_ = rx => (),