streaming/Priority
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

msg= string -> Message

Browse source
This commit is contained in:
Miki 2023-12-20 07:13:31 +00:00
parent 2289aa31fd
commit f4462e5df1
1 changed files with 7 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

13
sse/be/main.go
View file

@ -17,12 +17,12 @@ type Message struct {
type Event struct { type Event struct {
Message chan Message Message chan Message
NewClient chan chan string NewClient chan chan Message
ClosedClient chan chan string ClosedClient chan chan Message
TotalClients map[chan string]bool TotalClients map[chan Message]bool
} }
type ClientChan chan string type ClientChan chan Message
func main() { func main() {
@ -133,8 +133,9 @@ func (e *Event) Broadcast() {
id++ id++
message.Id = strconv.Itoa(id) message.Id = strconv.Itoa(id)
for client := range e.TotalClients { for client := range e.TotalClients {
msg, _ := json.Marshal(message) // msg, _ := json.Marshal(message)
client <- string(msg) // client <- string(msg)
client <- message
} }
} }
} }