Compare commits

..

2 Commits

Author SHA1 Message Date
1252b7a0d1 CICD preparation 2025-11-19 01:29:36 +03:00
1b9bb09ca4 Sketch 2025-11-19 01:29:21 +03:00

View File

@@ -18,7 +18,7 @@ type ChannelOut <-chan ClientPacket
type WebSocketQueue struct { type WebSocketQueue struct {
ctx context.Context ctx context.Context
ch chan ClientPacket ch chan ClientPacket.bumpversion.cfg
} }
func NewWebSocketQueue(ctx context.Context) *WebSocketQueue { func NewWebSocketQueue(ctx context.Context) *WebSocketQueue {
@@ -37,7 +37,7 @@ func NewWebSocketQueue(ctx context.Context) *WebSocketQueue {
func (q *WebSocketQueue) runWorker() { func (q *WebSocketQueue) runWorker() {
// создаём канал для ответов в вебсокет // создаём канал для ответов в вебсокет
log.Printf("[WS] Response worker is ready") log.Printf("[WS] Response worker is ready")
for packet := range q.ch { for packet := range ch {
q.realSend(packet) q.realSend(packet)
} }
} }