We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 10137fa commit e361137Copy full SHA for e361137
ws_js.go
@@ -55,6 +55,7 @@ type Conn struct {
55
closeWasClean bool
56
57
releaseOnClose func()
58
+ releaseOnError func()
59
releaseOnMessage func()
60
61
readSignal chan struct{}
@@ -92,9 +93,15 @@ func (c *Conn) init() {
92
93
c.close(err, e.WasClean)
94
95
c.releaseOnClose()
96
+ c.releaseOnError()
97
c.releaseOnMessage()
98
})
99
100
+ c.releaseOnError = c.ws.OnError(func(v js.Value) {
101
+ c.setCloseErr(errors.New(v.Get("message").String()))
102
+ c.closeWithInternal()
103
+ })
104
+
105
c.releaseOnMessage = c.ws.OnMessage(func(e wsjs.MessageEvent) {
106
c.readBufMu.Lock()
107
defer c.readBufMu.Unlock()
0 commit comments