diff options
| author | Kapten Z∅∅m <55669224+default-username-852@users.noreply.github.com> | 2021-02-13 22:07:19 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-02-13 22:07:19 +0100 |
| commit | f31577b69d2fa9c8fa32151083447f8e31936d95 (patch) | |
| tree | 5a9c32c89fed4da1b8284bc70ae28b9beccab39c /mumd/src/network | |
| parent | 89ce7ee42e4d57afaf6b21be46de0bcb98105dcb (diff) | |
| parent | 50e01f0c782ba0f52c832cabff0df966d9dcc803 (diff) | |
| download | mum-f31577b69d2fa9c8fa32151083447f8e31936d95.tar.gz | |
Merge pull request #64 from mum-rs/futures-cleanup
Dependency cleanup
Diffstat (limited to 'mumd/src/network')
| -rw-r--r-- | mumd/src/network/tcp.rs | 4 | ||||
| -rw-r--r-- | mumd/src/network/udp.rs | 6 |
2 files changed, 5 insertions, 5 deletions
diff --git a/mumd/src/network/tcp.rs b/mumd/src/network/tcp.rs index 3a32b9f..fa2681e 100644 --- a/mumd/src/network/tcp.rs +++ b/mumd/src/network/tcp.rs @@ -2,8 +2,8 @@ use crate::network::ConnectionInfo; use crate::state::{State, StatePhase}; use log::*; -use futures::{FutureExt, SinkExt, Stream, StreamExt}; -use futures_util::stream::{SplitSink, SplitStream}; +use futures_util::{FutureExt, SinkExt, StreamExt}; +use futures_util::stream::{SplitSink, SplitStream, Stream}; use mumble_protocol::control::{msgs, ClientControlCodec, ControlCodec, ControlPacket}; use mumble_protocol::crypt::ClientCryptState; use mumble_protocol::voice::VoicePacket; diff --git a/mumd/src/network/udp.rs b/mumd/src/network/udp.rs index 5f24b51..da92dcb 100644 --- a/mumd/src/network/udp.rs +++ b/mumd/src/network/udp.rs @@ -1,8 +1,8 @@ use crate::network::ConnectionInfo; use crate::state::{State, StatePhase}; -use futures::{join, FutureExt, SinkExt, StreamExt, Stream}; -use futures_util::stream::{SplitSink, SplitStream}; +use futures_util::{FutureExt, SinkExt, StreamExt}; +use futures_util::stream::{SplitSink, SplitStream, Stream}; use log::*; use mumble_protocol::crypt::ClientCryptState; use mumble_protocol::ping::{PingPacket, PongPacket}; @@ -14,7 +14,7 @@ use std::net::{Ipv6Addr, SocketAddr}; use std::rc::Rc; use std::sync::atomic::{AtomicU64, Ordering}; use std::sync::Arc; -use tokio::net::UdpSocket; +use tokio::{join, net::UdpSocket}; use tokio::sync::{mpsc, watch, Mutex}; use tokio::time::{interval, Duration}; use tokio_util::udp::UdpFramed; |
