merge

stream/websocket_server.go

@@ -3,6 +3,7 @@ package stream
 import (
 	"context"
 	"net/http"
+	"sync"
 
 	"gfx.cafe/open/goutil/generic"
 	"gfx.cafe/open/jsonpatch"
@@ -92,6 +93,7 @@ type WebsocketSubscriber struct {
 	topic string
 	ctx   context.Context
 	cn    context.CancelFunc
+	mu    sync.Mutex
 }
 
 func NewWssSubscriber(pctx context.Context, topic string, c *websocket.Conn) *WebsocketSubscriber {