Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 9a9c65c24c | |||
| 8a11ce0103 |
@@ -16,7 +16,7 @@ import (
|
|||||||
|
|
||||||
const (
|
const (
|
||||||
pingPeriod = 10 * time.Second
|
pingPeriod = 10 * time.Second
|
||||||
readDeadline = 30 * time.Second
|
readDeadline = 120 * time.Second
|
||||||
)
|
)
|
||||||
|
|
||||||
type SafeMap[K comparable, V any] struct {
|
type SafeMap[K comparable, V any] struct {
|
||||||
@@ -355,7 +355,7 @@ func (wsClient *SafeWebsocketClient) startPingTicker(ctx context.Context) {
|
|||||||
case <-ticker.C:
|
case <-ticker.C:
|
||||||
wsClient.writeChan <- Message{
|
wsClient.writeChan <- Message{
|
||||||
MessageType: websocket.PingMessage,
|
MessageType: websocket.PingMessage,
|
||||||
Data: nil,
|
Data: []byte{},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user