We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 45a705e commit 355346aCopy full SHA for 355346a
pkg/websocket/conn.go
@@ -2,6 +2,7 @@ package websocket
2
3
import (
4
"errors"
5
+ "net"
6
"sync"
7
"time"
8
@@ -46,7 +47,11 @@ func (conn *WebSocketConn) ReadMessage() {
46
47
if err != nil {
48
logger.Warnf("Got error: %v", err)
49
if c, k := err.(*websocket.CloseError); k {
- conn.Emit("error", c.Code, c.Text)
50
+ conn.Emit("close", c.Code, c.Text)
51
+ } else {
52
+ if c, k := err.(*net.OpError); k {
53
+ conn.Emit("close", 1008, c.Error())
54
+ }
55
}
56
close(stop)
57
break
0 commit comments