Method send_request

src/crates/services/services-core/src/lsp/process.rs:587–618

Sends a request and waits for the response.

(
        &self,
        method: impl Into<String>,
        params: Option<serde_json::Value>,
    )

    /// Sends a request and waits for the response.
    pub async fn send_request(
        &self,
        method: impl Into<String>,
        params: Option<serde_json::Value>,
    ) -> Result<serde_json::Value> {
        let id = self.request_id.fetch_add(1, Ordering::SeqCst);
        let method_str = method.into();

        let message = create_request(id, method_str.clone(), params);

        let (tx, rx) = oneshot::channel();

        {
            let mut pending = self.pending_requests.write().await;
            pending.insert(id, tx);
        }

        {
            let mut stdin = self.stdin.write().await;
            write_message(&mut stdin, &message).await?;
        }

        let response = timeout(Duration::from_secs(60), rx).await.map_err(|_| {
            error!("LSP request timeout after 60s: {}", method_str);
            anyhow!(
                "LSP request timeout (60s): {}. The LSP server may not be responding.",
                method_str
            )
        })??;

        extract_result(response)
    }

    /// Sends a notification (does not wait for a response).
    pub async fn send_notification(