remove unwraps

examples/webrtc.rs

@@ -102,13 +102,15 @@ async fn read_loop(mut stream: hbb_common::Stream) -> Result<()> {
             println!("WebRTC stream closed; Exit the read_loop");
             return Ok(());
         };
-        if res.is_err() {
-            println!("WebRTC stream read error: {}; Exit the read_loop", res.err().unwrap());
-            return Ok(());
+        match res {
+            Err(e) => {
+                println!("WebRTC stream read error: {}; Exit the read_loop", e);
+                return Ok(());
+            }
+            Ok(data) => {
+                println!("Message from stream: {}", String::from_utf8(data.to_vec())?);
+            }
         }
-        println!("Message from stream: {}",
-            String::from_utf8(res.unwrap().to_vec())?
-        );
     }
 }
 

src/webrtc.rs

@@ -105,7 +105,19 @@ impl WebRTCStream {
         let contains = lock.contains_key(&key);
         if contains {
             log::debug!("Start webrtc with cached peer");
-            return Ok(lock.get(&key).unwrap().clone());
+            return Ok(lock[&key].clone());
+        }
+        // ...existing code...
+            Self::get_remote_offer(remote_endpoint)?
+        };
+
+        let key = remote_offer.clone();
+        let mut lock = SESSIONS.lock().await;
+        if let Some(cached_stream) = lock.get(&key) {
+            if !key.is_empty() {
+                log::debug!("Start webrtc with cached peer");
+                return Ok(cached_stream.clone());
+            }
         }
 
         // Create a SettingEngine and enable Detach