Compare commits
2 Commits
1252b7a0d1
...
444d7cdfff
| Author | SHA1 | Date | |
|---|---|---|---|
| 444d7cdfff | |||
| 33e49e1a00 |
@@ -18,7 +18,7 @@ type ChannelOut <-chan ClientPacket
|
||||
|
||||
type WebSocketQueue struct {
|
||||
ctx context.Context
|
||||
ch chan ClientPacket.bumpversion.cfg
|
||||
ch chan ClientPacket
|
||||
}
|
||||
|
||||
func NewWebSocketQueue(ctx context.Context) *WebSocketQueue {
|
||||
@@ -37,7 +37,7 @@ func NewWebSocketQueue(ctx context.Context) *WebSocketQueue {
|
||||
func (q *WebSocketQueue) runWorker() {
|
||||
// создаём канал для ответов в вебсокет
|
||||
log.Printf("[WS] Response worker is ready")
|
||||
for packet := range ch {
|
||||
for packet := range q.ch {
|
||||
q.realSend(packet)
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user