Merge pull request #782 from AyaIbrahimm/master

moved pubq init cond to server constructor

Author: tidwall

internal/server/pubqueue.go

@@ -22,7 +22,6 @@ func (s *Server) startPublishQueue(wg *sync.WaitGroup) {
 	defer wg.Done()
 	var buf []byte
 	var conns []net.Conn
-	s.pubq.cond = sync.NewCond(&sync.Mutex{})
 	s.pubq.cond.L.Lock()
 	for {
 		for len(s.pubq.entries) > 0 {

internal/server/server.go

@@ -321,6 +321,7 @@ func Serve(opts Options) error {
 		conns:     make(map[int]*Client),
 		http:      opts.UseHTTP,
 		pubsub:    newPubsub(),
+		pubq:      pubQueue{cond: sync.NewCond(&sync.Mutex{})},
 		monconns:  make(map[net.Conn]bool),
 		cols:      &btree.Map[string, *collection.Collection]{},