diff options
| author | Eskil Queseth <eskilq@kth.se> | 2020-10-14 17:45:04 +0200 |
|---|---|---|
| committer | Eskil Queseth <eskilq@kth.se> | 2020-10-14 17:45:04 +0200 |
| commit | ab0cdc240c65fdc6b764ed17f6611786d449acc3 (patch) | |
| tree | bbad07ff338616c17208cf257eb3c6d359eb857e /mumd/src/audio.rs | |
| parent | e4406676a28f2dfb756f8f9e38a4242166f19c0e (diff) | |
| download | mum-ab0cdc240c65fdc6b764ed17f6611786d449acc3.tar.gz | |
add support for reconnecting to server
Diffstat (limited to 'mumd/src/audio.rs')
| -rw-r--r-- | mumd/src/audio.rs | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/mumd/src/audio.rs b/mumd/src/audio.rs index e13845e..aa06a9d 100644 --- a/mumd/src/audio.rs +++ b/mumd/src/audio.rs @@ -293,9 +293,13 @@ fn input_callback<T: Sample>( .unwrap(); opus_buf.truncate(result); let bytes = Bytes::copy_from_slice(&opus_buf); - input_sender - .try_send(VoicePacketPayload::Opus(bytes, false)) - .unwrap(); //TODO handle full buffer / disconnect + match input_sender + .try_send(VoicePacketPayload::Opus(bytes, false)) { //TODO handle full buffer / disconnect + Ok(_) => {}, + Err(_e) => { + //warn!("Error sending audio packet: {:?}", e); + } + } *buf = tail; } } |
