From deb87dceed46ae5bc0797c2f9149f046a388ed80 Mon Sep 17 00:00:00 2001 From: maddalax Date: Wed, 2 Oct 2024 12:56:11 -0500 Subject: [PATCH] test --- examples/chat/ws/manager.go | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/examples/chat/ws/manager.go b/examples/chat/ws/manager.go index 4d653f1..afb3a11 100644 --- a/examples/chat/ws/manager.go +++ b/examples/chat/ws/manager.go @@ -188,10 +188,19 @@ func (manager *SocketManager) writeCloseRaw(writer WriterChan, message string) { func (manager *SocketManager) writeTextRaw(writer WriterChan, event string, message string) { routine.DebugLongRunning("writeTextRaw", func() { + timeout := 3 * time.Second + data := "" if event != "" { - writer <- fmt.Sprintf("event: %s\ndata: %s\n\n", event, message) + data = fmt.Sprintf("event: %s\ndata: %s\n\n", event, message) } else { - writer <- fmt.Sprintf("data: %s\n\n", message) + data = fmt.Sprintf("data: %s\n\n", message) + } + fmt.Printf("writing to channel:\n") + select { + case writer <- data: + fmt.Println("Sent to the channel") + case <-time.After(timeout): + fmt.Printf("could not send %s to channel after %s\n", data, timeout) } }) }