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/audio.rs | |
| 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/audio.rs')
| -rw-r--r-- | mumd/src/audio.rs | 18 |
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); |
