aboutsummaryrefslogtreecommitdiffstats
path: root/mumd/src/main.rs
diff options
context:
space:
mode:
authorGustav Sörnäs <gustav@sornas.net>2020-10-10 22:25:05 +0200
committerGustav Sörnäs <gustav@sornas.net>2020-10-10 22:25:05 +0200
commitb3339294dac5a7f448de8c3849ab198afff8d14b (patch)
tree466c213ad504c4d8b36b4eefd9774ad3ed489779 /mumd/src/main.rs
parentab8116223328412484d1e76a9ff7b2055f05abf5 (diff)
downloadmum-b3339294dac5a7f448de8c3849ab198afff8d14b.tar.gz
handle multiple incoming audio streams
Co-authored-by: Eskil Queseth <eskilq@kth.se>
Diffstat (limited to 'mumd/src/main.rs')
-rw-r--r--mumd/src/main.rs10
1 files changed, 9 insertions, 1 deletions
diff --git a/mumd/src/main.rs b/mumd/src/main.rs
index 3960b48..4c3b67c 100644
--- a/mumd/src/main.rs
+++ b/mumd/src/main.rs
@@ -10,6 +10,8 @@ use futures::channel::oneshot;
use futures::join;
use mumble_protocol::crypt::ClientCryptState;
use std::net::ToSocketAddrs;
+use std::sync::Arc;
+use std::sync::Mutex;
#[tokio::main]
async fn main() {
@@ -47,6 +49,7 @@ async fn main() {
let audio = Audio::new();
audio.output_stream.play().unwrap();
+ let audio = Arc::new(Mutex::new(audio));
// Run it
join!(
@@ -56,7 +59,12 @@ async fn main() {
username,
accept_invalid_cert,
crypt_state_sender,
+ Arc::clone(&audio),
),
- network::handle_udp(server_addr, crypt_state_receiver, audio,)
+ network::handle_udp(
+ server_addr,
+ crypt_state_receiver,
+ audio,
+ )
);
}