diff --git a/main.go b/main.go index 6add2e5..4b60baa 100644 --- a/main.go +++ b/main.go @@ -107,7 +107,7 @@ func main() { c.Set("Cache-Control", "no-cache") c.Set("Connection", "keep-alive") - events := make(chan SSE) + events := make(chan SSE, 100) mu.Lock() clients[events] = true mu.Unlock() @@ -126,7 +126,8 @@ func main() { c.Context().SetBodyStreamWriter(func(w *bufio.Writer) { for event := range events { if _, err := fmt.Fprintf(w, "event: %s\ndata: %s\n\n", event.Event, event.Data); err != nil { - panic(err) + fmt.Println(err) + return } w.Flush() }