MCPcopy Create free account
hub / github.com/astercloud/aster / handleMessageStream

Method handleMessageStream

pkg/a2a/server.go:194–198  ·  view source on GitHub ↗

handleMessageStream 处理 message/stream 方法

(_ context.Context, _ string, req *JSONRPCRequest)

Source from the content-addressed store, hash-verified

192
193// handleMessageStream 处理 message/stream 方法
194func (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 方法
201func (s *Server) handleTasksGet(_ context.Context, agentID string, req *JSONRPCRequest) *JSONRPCResponse {

Callers 1

HandleRequestMethod · 0.95

Calls 1

NewErrorResponseFunction · 0.85

Tested by

no test coverage detected