Method call

crates/opencode-plugin/src/subprocess/client.rs:423–443

Send a JSON-RPC request and wait for the response.

(
        &self,
        method: &str,
        params: Option<Value>,
    )

    /// Send a JSON-RPC request and wait for the response.
    async fn call<T: serde::de::DeserializeOwned>(
        &self,
        method: &str,
        params: Option<Value>,
    ) -> Result<T, PluginSubprocessError> {
        let _rpc_guard = self.rpc_lock.lock().await;
        let id = self.next_id();
        self.write_request(id, method, params).await?;

        // Read response with timeout
        let response = tokio::time::timeout(self.timeout, self.read_response_for_id(id))
            .await
            .map_err(|_| PluginSubprocessError::Timeout)??;

        if let Some(err) = response.error {
            return Err(err.into());
        }

        let result = response.result.unwrap_or(Value::Null);
        serde_json::from_value(result).map_err(Into::into)
    }

    async fn write_request(
        &self,