pomodoro/GoTomato
3
0
Fork 0
Code Issues Pull requests Releases 15 Activity

feat: add a ticker to manage broadcast timing

Browse source
This commit is contained in:
Sebastian Mark 2024-10-25 23:15:48 +02:00
parent d256235c1b
commit 62fbb1d356
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
internal/websocket/broadcast.go
View file

@ -10,6 +10,7 @@ import (
// sends continous messages to all connected WebSocket clients. // sends continous messages to all connected WebSocket clients.
func SendPermanentBroadCastMessage() { func SendPermanentBroadCastMessage() {
tick := time.NewTicker(time.Second)
for { for {
// Marshal the message into JSON format // Marshal the message into JSON format
jsonMessage, err := json.Marshal(shared.Message) jsonMessage, err := json.Marshal(shared.Message)
@ -25,6 +26,6 @@ func SendPermanentBroadCastMessage() {
// The client is responsible for closing itself on error // The client is responsible for closing itself on error
} }
} }
time.Sleep(time.Second) <-tick.C
} }
} }