ResponseApiHandler
public class ResponseApiHandler源码Source
io/agentscope/runtime/protocol/responseapi/ResponseApiHandler.java:36–400响应 API 处理器，承载智能体的部署、调度与服务化运行。位于 io.agentscope.runtime.protocol.responseapi 包。核心成员包括 handleStreamingResponse、handleStreamingFlux、handleNonStreamingResponse、ResponseApiHandler。
Handler for OpenAI Responses API requests.
构造器摘要Constructor Summary
| 构造器Constructor | 说明Description |
|---|---|
public ResponseApiHandler(Runner runner, ResponseApiProtocolConfig config) | 初始化 `ResponseApiHandler` 实例。 Creates a new instance. |
方法摘要Method Summary
| 方法Method | 说明Description |
|---|---|
public Flux<RealtimeServerEvent> handleStreamingResponse(ResponseApiRequest requestBody) | 处理流式响应。 Handle chat completion request and return streaming response. |
public Flux<RealtimeServerEvent> handleStreamingFlux(Flux<Event> eventFlux) | 处理 `handleStreamingFlux`。 Performs the handle streaming flux operation. |
public ResponseApiResponse handleNonStreamingResponse(ResponseApiRequest requestBody) | 处理 `handleNonStreamingResponse`。 Handle non-streaming request and return aggregated response. |
构造器详情Constructor Detail
ResponseApiHandler
public ResponseApiHandler(Runner runner, ResponseApiProtocolConfig config)初始化 ResponseApiHandler 实例。
Creates a new instance.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
runner | Runner | 运行器（类型 `Runner`）。The runner. |
config | ResponseApiProtocolConfig | 配置对象（类型 `ResponseApiProtocolConfig`）。The config. |
源码Source
io/agentscope/runtime/protocol/responseapi/ResponseApiHandler.java:43–46方法详情Method Detail
handleStreamingResponse
public Flux<RealtimeServerEvent> handleStreamingResponse(ResponseApiRequest requestBody)处理流式响应。
Handle chat completion request and return streaming response.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
requestBody | ResponseApiRequest | 请求正文（类型 `ResponseApiRequest`）。the request body containing messages |
Flux<RealtimeServerEvent>返回Flux。Flux of ResponseStreamEvent
源码Source
io/agentscope/runtime/protocol/responseapi/ResponseApiHandler.java:54–70handleStreamingFlux
public Flux<RealtimeServerEvent> handleStreamingFlux(Flux<Event> eventFlux)处理 handleStreamingFlux。
Performs the handle streaming flux operation.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
eventFlux | Flux<Event> | 事件 Flux（类型 `Flux`）。The event flux. |
Flux<RealtimeServerEvent>返回Flux。Returns flux.
源码Source
io/agentscope/runtime/protocol/responseapi/ResponseApiHandler.java:72–112handleNonStreamingResponse
public ResponseApiResponse handleNonStreamingResponse(ResponseApiRequest requestBody)处理 handleNonStreamingResponse。
Handle non-streaming request and return aggregated response.
参数Parameters
| 名称Name | 类型Type | 说明Description |
|---|---|---|
requestBody | ResponseApiRequest | 请求正文（类型 `ResponseApiRequest`）。The request body. |
ResponseApiResponse返回ResponseApiResponse。Returns response api response.
源码Source
io/agentscope/runtime/protocol/responseapi/ResponseApiHandler.java:117–179