(c *gin.Context, event string, payload interface{})
| 854 | } |
| 855 | |
| 856 | func writeImageStreamEvent(c *gin.Context, event string, payload interface{}) bool { |
| 857 | data, err := json.Marshal(payload) |
| 858 | if err != nil { |
| 859 | return false |
| 860 | } |
| 861 | if event != "" { |
| 862 | if _, err := c.Writer.WriteString("event: " + event + "\n"); err != nil { |
| 863 | return false |
| 864 | } |
| 865 | } |
| 866 | if _, err := c.Writer.WriteString("data: "); err != nil { |
| 867 | return false |
| 868 | } |
| 869 | if _, err := c.Writer.Write(data); err != nil { |
| 870 | return false |
| 871 | } |
| 872 | if _, err := c.Writer.WriteString("\n\n"); err != nil { |
| 873 | return false |
| 874 | } |
| 875 | c.Writer.Flush() |
| 876 | return true |
| 877 | } |
| 878 | |
| 879 | func writeImageStreamDone(c *gin.Context) bool { |
| 880 | if _, err := c.Writer.WriteString("data: [DONE]\n\n"); err != nil { |
no test coverage detected