fix ws.close #41 thanks @seanr3

pull/39/head
Ciro 2022-12-01 07:57:14 -03:00
rodzic 2dd71241be
commit e2b9c8a969
2 zmienionych plików z 39 dodań i 1 usunięć

Wyświetl plik

@ -0,0 +1,38 @@
from socketify import App, AppOptions, OpCode, CompressOptions
def ws_open(ws):
print("A WebSocket got connected!")
ws.send("Hello World!", OpCode.TEXT)
def ws_message(ws, message, opcode):
print(message, opcode)
if message == 'close':
ws.close()
else:
# Ok is false if backpressure was built up, wait for drain
ok = ws.send(message, opcode)
app = App()
app.ws(
"/*",
{
"compression": CompressOptions.SHARED_COMPRESSOR,
"max_payload_length": 16 * 1024 * 1024,
"idle_timeout": 12,
"open": ws_open,
"message": ws_message,
"drain": lambda ws: print(
"WebSocket backpressure: %s", ws.get_buffered_amount()
),
"close": lambda ws, code, message: print("WebSocket closed"),
},
)
app.any("/", lambda res, req: res.end("Nothing to see here!'"))
app.listen(
3000,
lambda config: print("Listening on port http://localhost:%d now\n" % (config.port)),
)
app.run()

Wyświetl plik

@ -1189,7 +1189,7 @@ class WebSocket:
return self
def close(self):
lib.uws_ws_close(self.SSL, self._ptr)
lib.uws_ws_close(self.SSL, self.ws)
return self
def cork(self, callback):