From f4462e5df120a45b7d1e72f2166778fa24b3d3b7 Mon Sep 17 00:00:00 2001 From: Miki Date: Wed, 20 Dec 2023 07:13:31 +0000 Subject: [PATCH] msg= string -> Message --- sse/be/main.go | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/sse/be/main.go b/sse/be/main.go index 1500310..3e7cebf 100644 --- a/sse/be/main.go +++ b/sse/be/main.go @@ -17,12 +17,12 @@ type Message struct { type Event struct { Message chan Message - NewClient chan chan string - ClosedClient chan chan string - TotalClients map[chan string]bool + NewClient chan chan Message + ClosedClient chan chan Message + TotalClients map[chan Message]bool } -type ClientChan chan string +type ClientChan chan Message func main() { @@ -133,8 +133,9 @@ func (e *Event) Broadcast() { id++ message.Id = strconv.Itoa(id) for client := range e.TotalClients { - msg, _ := json.Marshal(message) - client <- string(msg) + // msg, _ := json.Marshal(message) + // client <- string(msg) + client <- message } } }