Function hasJSONRPCSSE

jsonrpc/codegen/server.go:172–186

hasJSONRPCSSE returns true if the service uses SSE for JSON-RPC streaming.

(svc *expr.HTTPServiceExpr, data *httpcodegen.ServicesData)

// hasJSONRPCSSE returns true if the service uses SSE for JSON-RPC streaming.
func hasJSONRPCSSE(svc *expr.HTTPServiceExpr, data *httpcodegen.ServicesData) bool {
	svcData := data.Get(svc.Name())
	if svcData == nil {
		return false
	}

	// Check if any JSON-RPC streaming endpoint uses SSE
	for _, e := range svc.HTTPEndpoints {
		if e.MethodExpr.IsStreaming() && e.IsJSONRPC() && e.SSE != nil {
			return true
		}
	}

	return false
}

// hasJSONRPCHTTP returns true if the service has non-streaming JSON-RPC endpoints.
func hasJSONRPCHTTP(svc *expr.HTTPServiceExpr) bool {