Method ensure_polled_agent

packages/server/src/inspector.rs:234–268

(&self, process_identifier: i64)

    }

    pub async fn ensure_polled_agent(&self, process_identifier: i64) -> Result<(), String> {
        {
            let mut inner = self.inner.lock().await;
            inner.prune_stale_polled_agents();
            if inner.agents.contains_key(&process_identifier) {
                return Ok(());
            }
            if inner.agents.len() >= MAX_POLLED_AGENTS {
                return Err("Too many pending NativeScript inspector agents.".to_owned());
            }
        }

        let connection_id = self.allocate_connection_id().await;
        let (outgoing, _receiver) = mpsc::channel::<Value>(1);
        let outbox = Arc::new(Mutex::new(VecDeque::new()));
        outbox.lock().await.push_back(json!({
            "id": POLLED_INFO_REQUEST_ID,
            "method": "Inspector.getInfo",
            "params": Value::Null,
        }));

        let agent = InspectorAgentHandle {
            connection_id,
            created_at: Instant::now(),
            info: Value::Null,
            outgoing,
            outbox,
            outbox_notify: Arc::new(Notify::new()),
            pending: Arc::new(Mutex::new(HashMap::new())),
            next_request_id: Arc::new(AtomicU64::new(1)),
        };

        self.register(process_identifier, agent).await;
        Ok(())
    }

    pub async fn query_with_timeout(
        &self,