Merge pull request #233 from jokemanfire/dev2

If streams cannot be locked, it will cause a panic

Author: Tim-Zhang

src/asynchronous/client.rs

@@ -76,8 +76,10 @@ impl Client {
 
         let (tx, mut rx): (ResultSender, ResultReceiver) = mpsc::channel(100);
 
-        // TODO: check return.
-        self.streams.lock().unwrap().insert(stream_id, tx);
+        self.streams
+            .lock()
+            .map_err(|_| Error::Others("Failed to acquire lock on streams".to_string()))?
+            .insert(stream_id, tx);
 
         self.req_tx
             .send(SendingMessage::new(msg))
@@ -138,8 +140,11 @@ impl Client {
         }
 
         let (tx, rx): (ResultSender, ResultReceiver) = mpsc::channel(100);
-        // TODO: check return
-        self.streams.lock().unwrap().insert(stream_id, tx);
+        self.streams
+            .lock()
+            .map_err(|_| Error::Others("Failed to acquire lock on streams".to_string()))?
+            .insert(stream_id, tx);
+
         self.req_tx
             .send(SendingMessage::new(msg))
             .await