Working req res

crates/analyzer/src/rust_analyzer.rs

@@ -135,18 +135,25 @@ impl RustAnalyzer {
             let pending = self.pending.clone();
 
             tokio::spawn(async move {
-                let raw_string = read_lsp_message(&mut *stdout.lock().await).await.unwrap();
+                loop {
+                    let raw_string = read_lsp_message(&mut *stdout.lock().await).await.unwrap();
 
-                let envelope: JsonRpcResponse<Value> = serde_json::from_str(&raw_string).unwrap();
+                    let envelope: JsonRpcResponse<Value> =
+                        serde_json::from_str(&raw_string).unwrap();
 
-                pending
+                    pending
-                    .lock()
+                        .lock()
-                    .await
+                        .await
-                    .get(&envelope.id.unwrap())
+                        .remove(&envelope.id.unwrap())
-                    .unwrap()
+                        .unwrap()
-                    .send(raw_string)
+                        .send(raw_string)
-                    .await
+                        .await
-                    .unwrap();
+                        .unwrap();
+
+                    if pending.lock().await.len() == 0 {
+                        break;
+                    }
+                }
             });
         }