Add error handling

[m17rt] / m17codec2 / src / lib.rs

diff --git a/m17codec2/src/lib.rs b/m17codec2/src/lib.rs
index c338f6ae1cdeb46daac2a28059e7af2469abc4c6..2f05701f20b50deaaa6a68966eb83ea35ff27cce 100755 (executable)
--- a/m17codec2/src/lib.rs
+++ b/m17codec2/src/lib.rs
@@ -91,7 +91,7 @@ impl StreamAdapter for Codec2Adapter {
         std::thread::spawn(move || stream_thread(end_rx, setup_tx, state, output_card));
         self.state.lock().unwrap().end_tx = Some(end_tx);
         // Propagate any errors arising in the thread
         std::thread::spawn(move || stream_thread(end_rx, setup_tx, state, output_card));
         self.state.lock().unwrap().end_tx = Some(end_tx);
         // Propagate any errors arising in the thread

-        Ok(setup_rx.recv()??)
+        setup_rx.recv()?

     }
 
     fn close(&self) -> Result<(), AdapterError> {
     }
 
     fn close(&self) -> Result<(), AdapterError> {