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 9bc627b commit a6dc6ccCopy full SHA for a6dc6cc
src/websocket/client_ev.lua
@@ -142,9 +142,7 @@ local ev = function(ws)
142
req,
143
function()
144
local resp = {}
145
- -- assert(sock:getfd() > -1)
146
local response = ''
147
-
148
local read_upgrade = function(loop,read_io)
149
repeat
150
local byte,err,pp = sock:receive(1)
@@ -208,6 +206,10 @@ local ev = function(ws)
208
206
end
209
207
210
self.close = function(_,code,reason,timeout)
+ if handshake_io then
+ handshake_io:stop(loop)
211
+ handshake_io:clear_pending(loop)
212
+ end
213
if self.state == 'CONNECTING' then
214
self.state = 'CLOSING'
215
on_close(false,1006,'')
0 commit comments