aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/audio.rs
diff options
context:
space:
mode:
authorKapten Z∅∅m <55669224+default-username-852@users.noreply.github.com>2021-02-13 22:07:19 +0100
committerGitHub <noreply@github.com>2021-02-13 22:07:19 +0100
commitf31577b69d2fa9c8fa32151083447f8e31936d95 (patch)
tree5a9c32c89fed4da1b8284bc70ae28b9beccab39c /mumd/src/audio.rs
parent89ce7ee42e4d57afaf6b21be46de0bcb98105dcb (diff)
parent50e01f0c782ba0f52c832cabff0df966d9dcc803 (diff)
downloadmum-f31577b69d2fa9c8fa32151083447f8e31936d95.tar.gz
Merge pull request #64 from mum-rs/futures-cleanup
Dependency cleanup
Diffstat (limited to 'mumd/src/audio.rs')
-rw-r--r--mumd/src/audio.rs18
1 files changed, 3 insertions, 15 deletions
diff --git a/mumd/src/audio.rs b/mumd/src/audio.rs
index 94b1abd..eee6716 100644
--- a/mumd/src/audio.rs
+++ b/mumd/src/audio.rs
@@ -10,25 +10,13 @@ use dasp_frame::Frame;
use dasp_interpolate::linear::Linear;
use dasp_sample::{SignedSample, ToSample, Sample};
use dasp_signal::{self as signal, Signal};
-use futures::Stream;
-use futures::stream::StreamExt;
-use futures::task::{Context, Poll};
+use futures_util::{StreamExt, stream::Stream};
use log::*;
use mumble_protocol::Serverbound;
use mumble_protocol::voice::{VoicePacketPayload, VoicePacket};
use mumlib::config::SoundEffect;
use opus::Channels;
-use std::{
- borrow::Cow,
- collections::{hash_map::Entry, HashMap, VecDeque},
- convert::TryFrom,
- fmt::Debug,
- fs::File,
- future::Future,
- io::Read,
- pin::Pin,
- sync::{Arc, Mutex},
-};
+use std::{borrow::Cow, collections::{hash_map::Entry, HashMap, VecDeque}, convert::TryFrom, fmt::Debug, fs::File, future::Future, io::Read, pin::Pin, sync::{Arc, Mutex}, task::{Context, Poll}};
use strum::IntoEnumIterator;
use strum_macros::EnumIter;
use tokio::sync::watch;
@@ -171,7 +159,7 @@ impl Audio {
}
.unwrap();
- let (sample_sender, sample_receiver) = futures::channel::mpsc::channel(1_000_000);
+ let (sample_sender, sample_receiver) = futures_channel::mpsc::channel(1_000_000);
let (input_volume_sender, input_volume_receiver) = watch::channel::<f32>(input_volume);