Compare commits
2 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 78a5b21531 | |||
| e011931436 |
@@ -117,7 +117,7 @@ func ReadPump(c *Client, h *Hub) {
|
||||
for {
|
||||
messageType, message, err := c.Conn.ReadMessage()
|
||||
if err != nil {
|
||||
if !websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
|
||||
if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
|
||||
log.Printf("WebSocket error: %v", err)
|
||||
}
|
||||
break
|
||||
|
||||
@@ -16,7 +16,7 @@ import (
|
||||
|
||||
const (
|
||||
pingPeriod = 10 * time.Second
|
||||
readDeadline = 120 * time.Second
|
||||
readDeadline = 30 * time.Second
|
||||
)
|
||||
|
||||
type SafeMap[K comparable, V any] struct {
|
||||
@@ -68,10 +68,10 @@ func (sm *SafeMap[K, V]) Len() int {
|
||||
type MessageType uint
|
||||
|
||||
const (
|
||||
MessageTypeText MessageType = iota + 1
|
||||
MessageTypePing MessageType = iota
|
||||
MessageTypePong MessageType = iota
|
||||
MessageTypeClose MessageType = iota
|
||||
MessageTypeText MessageType = websocket.TextMessage
|
||||
MessageTypePing MessageType = websocket.PingMessage
|
||||
MessageTypePong MessageType = websocket.PongMessage
|
||||
MessageTypeClose MessageType = websocket.CloseMessage
|
||||
)
|
||||
|
||||
type Message struct {
|
||||
|
||||
Reference in New Issue
Block a user