Method query

packages/server/src/inspector.rs:674–698

(&self, method: &str, params: Value, wait: Duration)

impl InspectorAgentHandle {
    async fn query(&self, method: &str, params: Value, wait: Duration) -> Result<Value, String> {
        let id = self.next_request_id.fetch_add(1, Ordering::Relaxed);
        let request = json!({
            "id": id,
            "method": method,
            "params": params,
        });
        let (response_tx, response_rx) = oneshot::channel();
        self.pending.lock().await.insert(id, response_tx);

        self.outbox.lock().await.push_back(request.clone());
        self.outbox_notify.notify_waiters();
        let _ = self.outgoing.send(request).await;

        match timeout(wait, response_rx).await {
            Ok(Ok(result)) => result,
            Ok(Err(_)) => Err("NativeScript inspector response channel closed.".to_owned()),
            Err(_) => {
                self.pending.lock().await.remove(&id);
                Err(format!(
                    "Timed out waiting for NativeScript inspector method {method}."
                ))
            }
        }
    }

    async fn poll(&self, wait: Duration) -> Result<Option<Value>, String> {
        let deadline = Instant::now() + wait;