diff options
| author | Gustav Sörnäs <gustav@sornas.net> | 2020-10-10 22:25:05 +0200 |
|---|---|---|
| committer | Gustav Sörnäs <gustav@sornas.net> | 2020-10-10 22:25:05 +0200 |
| commit | b3339294dac5a7f448de8c3849ab198afff8d14b (patch) | |
| tree | 466c213ad504c4d8b36b4eefd9774ad3ed489779 /mumd/src/main.rs | |
| parent | ab8116223328412484d1e76a9ff7b2055f05abf5 (diff) | |
| download | mum-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.rs | 10 |
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, + ) ); } |
