diff --git a/go.mod b/go.mod index f5456c3..a3b172b 100644 --- a/go.mod +++ b/go.mod @@ -1,6 +1,6 @@ module repositories.action2quare.com/ayo/gocommon -go 1.19 +go 1.20 replace repositories.action2quare.com/ayo/gocommon => ./ diff --git a/wshandler/room.go b/wshandler/room.go index 762e165..35fb313 100644 --- a/wshandler/room.go +++ b/wshandler/room.go @@ -76,9 +76,7 @@ func (r *room) loop(ctx context.Context, conns *map[string]*wsconn) (normalEnd b bt, _ := json.Marshal(ds) for _, conn := range *conns { - writer, _ := conn.NextWriter(websocket.TextMessage) - writer.Write(bt) - writer.Close() + conn.Conn.WriteMessage(websocket.TextMessage, bt) } } }