diff options
| author | Gustav Sörnäs <gustav@sornas.net> | 2020-10-17 03:25:17 +0200 |
|---|---|---|
| committer | Gustav Sörnäs <gustav@sornas.net> | 2020-10-17 03:25:17 +0200 |
| commit | 47c3c5ca605fc8f2558ddb612bcc0eebcd484000 (patch) | |
| tree | 314fead020ccae8eb577c7285f8b8295c1c853ef /mumd | |
| parent | f69fa83b4656635e104b7b7c9867565bbcaf18eb (diff) | |
| download | mum-47c3c5ca605fc8f2558ddb612bcc0eebcd484000.tar.gz | |
remove some TODOs handled as issues
Diffstat (limited to 'mumd')
| -rw-r--r-- | mumd/src/audio.rs | 7 | ||||
| -rw-r--r-- | mumd/src/network/tcp.rs | 1 |
2 files changed, 2 insertions, 6 deletions
diff --git a/mumd/src/audio.rs b/mumd/src/audio.rs index a63e0cc..828942b 100644 --- a/mumd/src/audio.rs +++ b/mumd/src/audio.rs @@ -20,7 +20,6 @@ struct ClientStream { opus_decoder: opus::Decoder, } -//TODO remove pub where possible pub struct Audio { pub output_config: StreamConfig, pub output_stream: Stream, @@ -28,13 +27,12 @@ pub struct Audio { pub input_config: StreamConfig, pub input_stream: Stream, pub input_buffer: Arc<Mutex<VecDeque<f32>>>, - input_channel_receiver: Option<Receiver<VoicePacketPayload>>, //TODO unbounded? mbe ring buffer and drop the first packet + input_channel_receiver: Option<Receiver<VoicePacketPayload>>, input_volume_sender: watch::Sender<f32>, - client_streams: Arc<Mutex<HashMap<u32, ClientStream>>>, //TODO move to user state + client_streams: Arc<Mutex<HashMap<u32, ClientStream>>>, } -//TODO split into input/output impl Audio { pub fn new() -> Self { let host = cpal::default_host(); @@ -324,7 +322,6 @@ fn input_callback<T: Sample>( opus_buf.truncate(result); let bytes = Bytes::copy_from_slice(&opus_buf); match input_sender.try_send(VoicePacketPayload::Opus(bytes, false)) { - //TODO handle full buffer / disconnect Ok(_) => {} Err(_e) => { //warn!("Error sending audio packet: {:?}", e); diff --git a/mumd/src/network/tcp.rs b/mumd/src/network/tcp.rs index ea4ef86..88d2b59 100644 --- a/mumd/src/network/tcp.rs +++ b/mumd/src/network/tcp.rs @@ -233,7 +233,6 @@ async fn listen( break; } Some(Some(packet)) => { - //TODO handle types separately match packet.unwrap() { ControlPacket::TextMessage(msg) => { info!( |