SSEServerFiles returns the generated JSON-RPC SSE server files if any.
(genpkg string, data *httpcodegen.ServicesData)
| 10 | |
| 11 | // SSEServerFiles returns the generated JSON-RPC SSE server files if any. |
| 12 | func SSEServerFiles(genpkg string, data *httpcodegen.ServicesData) []*codegen.File { |
| 13 | var files []*codegen.File |
| 14 | jsvcs := data.Root.API.JSONRPC.Services |
| 15 | for _, svc := range jsvcs { |
| 16 | if f := sseServerFile(genpkg, svc, data); f != nil { |
| 17 | files = append(files, f) |
| 18 | } |
| 19 | if f := sseClientFile(genpkg, svc, data); f != nil { |
| 20 | files = append(files, f) |
| 21 | } |
| 22 | } |
| 23 | return files |
| 24 | } |
| 25 | |
| 26 | // sseServerFile returns the file implementing the SSE server streaming implementation if any. |
| 27 | func sseServerFile(genpkg string, svc *expr.HTTPServiceExpr, services *httpcodegen.ServicesData) *codegen.File { |