Compare commits
2 Commits
1252b7a0d1
...
master
| Author | SHA1 | Date | |
|---|---|---|---|
| 444d7cdfff | |||
| 33e49e1a00 |
@@ -18,7 +18,7 @@ type ChannelOut <-chan ClientPacket
|
|||||||
|
|
||||||
type WebSocketQueue struct {
|
type WebSocketQueue struct {
|
||||||
ctx context.Context
|
ctx context.Context
|
||||||
ch chan ClientPacket.bumpversion.cfg
|
ch chan ClientPacket
|
||||||
}
|
}
|
||||||
|
|
||||||
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 ch {
|
for packet := range q.ch {
|
||||||
q.realSend(packet)
|
q.realSend(packet)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user