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