@Preview(value="3.8.1") public class ReActRequest extends java.lang.Object implements AgentRequest<ReActRequest,ReActResponse>
采用 Fluent API 风格,封装了单次 Agent 调用的完整参数。
它是线程不安全的,每个请求应由 ReActAgent.prompt(Prompt) 独立创建。
| 构造器和说明 |
|---|
ReActRequest(ReActAgent agent,
Prompt prompt) |
| 限定符和类型 | 方法和说明 |
|---|---|
ReActResponse |
call()
执行同步调用:阻塞当前线程直至推理完成或超时
|
ReActRequest |
options(java.util.function.Consumer<ReActOptionsAmend> adjustor)
修改当前请求的运行选项
|
ReActRequest |
session(AgentSession session)
绑定持久化会话:用于维持长期记忆或多轮对话上下文
|
reactor.core.publisher.Flux<AgentChunk> |
stream()
响应式流输出:实时推送推理过程中的 Chunk(如 ReasonChunk, ActionChunk)
适用于 Web 端 SSE 或 WebSocket 实时展示思考过程
|
public ReActRequest(ReActAgent agent, Prompt prompt)
public ReActRequest session(AgentSession session)
session 在接口中 AgentRequest<ReActRequest,ReActResponse>public ReActRequest options(java.util.function.Consumer<ReActOptionsAmend> adjustor)
public ReActResponse call() throws java.lang.Throwable
call 在接口中 AgentRequest<ReActRequest,ReActResponse>java.lang.Throwablepublic reactor.core.publisher.Flux<AgentChunk> stream()
stream 在接口中 AgentRequest<ReActRequest,ReActResponse>