(raw json.RawMessage, out any)
| 394 | defer unregister() |
| 395 | defer conn.Close() |
| 396 | for { |
| 397 | var req RPCRequest |
| 398 | if err := conn.ReadJSON(&req); err != nil { |
| 399 | return |
| 400 | } |
| 401 | result, err := s.teamManager.HandleA2A(r.Context(), teamSessionID, agentID, req.Method, req.Params) |
| 402 | if err != nil { |
| 403 | _ = conn.WriteJSON(RPCResponse{ID: req.ID, OK: false, Error: &RPCError{Code: "a2a_error", Message: err.Error()}}) |
| 404 | continue |
no outgoing calls
no test coverage detected