Struct WebSocketHumanLoopProvider 

pub struct WebSocketHumanLoopProvider { /* private fields */ }

Available on crate feature human-loop only.

WebSocket 人工介入 Provider。

在本地启动 WebSocket 服务器，向已连接的客户端推送审批/输入请求， 并异步等待第一个响应。适合与 Web UI、移动端或自定义工具集成。

使用方法

// Requires the `websocket` feature.

协议

服务端 → 客户端：

{
  "kind": "approval" | "input",
  "request_id": "uuid",
  "prompt": "...",
  "tool_name": "xxx",
  "args": { ... }
}

客户端 → 服务端：

{
  "request_id": "uuid",
  "decision": "approved" | "rejected",
  "text": "用户输入（input 场景）",
  "reason": "可选说明"
}

Implementations

impl WebSocketHumanLoopProvider

pub async fn bind(port: u16) -> Result<WebSocketHumanLoopProvider, Error>

绑定端口并启动 WebSocket 服务器，默认超时 5 分钟。

pub async fn bind_with_timeout( port: u16, timeout: Duration, ) -> Result<WebSocketHumanLoopProvider, Error>

绑定端口并启动 WebSocket 服务器，自定义超时。

Trait Implementations

impl HumanLoopProvider for WebSocketHumanLoopProvider

fn request( &self, req: HumanLoopRequest, ) -> Pin<Box<dyn Future<Output = Result<HumanLoopResponse, ReactError>> + Send + '_>>

发起人工介入请求