fix immediate loading of cached viewers

StreamPets · Jan 9, 2025 · b1217fe · b1217fe
1 parent a0e143b
commit b1217fe
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/controllers/overlay.go b/controllers/overlay.go
@@ -79,9 +79,11 @@ func (c *OverlayController) HandleListen(ctx *gin.Context) {
 	ticker := time.NewTicker(60 * time.Second)
 	defer ticker.Stop()
 
-	for _, viewer := range c.Cache.GetViewers(channelID) {
-		ctx.SSEvent("JOIN", viewer)
-	}
+	go func() {
+		for _, viewer := range c.Cache.GetViewers(channelID) {
+			client.Stream <- services.Event{Event: "JOIN", Message: viewer}
+		}
+	}()
 
 	ctx.Stream(func(w io.Writer) bool {
 		select {