Method cancel_turn

src/crates/execution/agent-runtime/src/runtime.rs:587–599

(
        &self,
        request: AgentTurnCancellationRequest,
    )

    }

    pub async fn cancel_turn(
        &self,
        request: AgentTurnCancellationRequest,
    ) -> Result<AgentTurnCancellationResult, RuntimeError> {
        let cancellation = self
            .cancellation
            .as_ref()
            .ok_or(RuntimeError::MissingCancellationPort)?;
        cancellation
            .cancel_turn(request)
            .await
            .map_err(RuntimeError::from)
    }

    pub async fn publish_event(&self, event: RuntimeEventEnvelope) -> Result<(), RuntimeError> {
        if self.services.is_none() && self.event_stream.is_none() {