Method send_request

crates/core/src/plugins/nemo_guardrails/python.rs:499–512

(&self, payload: &mut Json)

    }

    fn send_request(&self, payload: &mut Json) -> FlowResult<std_mpsc::Receiver<WorkerEnvelope>> {
        let id = self.next_request_id();
        set_request_id(payload, &id)?;
        let (tx, rx) = std_mpsc::channel();
        self.waiters
            .lock()
            .map_err(|err| FlowError::Internal(format!("worker waiter lock poisoned: {err}")))?
            .insert(id.clone(), tx);
        if let Err(err) = self.write_command(payload) {
            let _ = self.waiters.lock().map(|mut waiters| waiters.remove(&id));
            return Err(err);
        }
        Ok(rx)
    }

    fn start_stream(
        &self,