handleMessageStream 处理 message/stream 方法
(_ context.Context, _ string, req *JSONRPCRequest)
| 192 | |
| 193 | // handleMessageStream 处理 message/stream 方法 |
| 194 | func (s *Server) handleMessageStream(_ context.Context, _ string, req *JSONRPCRequest) *JSONRPCResponse { |
| 195 | // 流式响应需要特殊处理,这里先返回不支持 |
| 196 | return NewErrorResponse(req.ID, ErrorCodeUnsupportedOperation, |
| 197 | "streaming not yet implemented", nil) |
| 198 | } |
| 199 | |
| 200 | // handleTasksGet 处理 tasks/get 方法 |
| 201 | func (s *Server) handleTasksGet(_ context.Context, agentID string, req *JSONRPCRequest) *JSONRPCResponse { |
no test coverage detected