forked from retoor/snek
Unbuffered.
This commit is contained in:
@@ -27,8 +27,8 @@ class SocketService(BaseService):
|
|||||||
try:
|
try:
|
||||||
await ws.send_json(message)
|
await ws.send_json(message)
|
||||||
except Exception as ex:
|
except Exception as ex:
|
||||||
print(ex)
|
print(ex,flush=True)
|
||||||
print("Deleting socket.")
|
print("Deleting socket.",flush=True)
|
||||||
self.subscriptions[channel_uid].remove(ws)
|
self.subscriptions[channel_uid].remove(ws)
|
||||||
continue
|
continue
|
||||||
count += 1
|
count += 1
|
||||||
@@ -37,4 +37,4 @@ class SocketService(BaseService):
|
|||||||
try:
|
try:
|
||||||
self.sockets.remove(ws)
|
self.sockets.remove(ws)
|
||||||
except IndexError:
|
except IndexError:
|
||||||
pass
|
pass
|
||||||
|
|||||||
Reference in New Issue
Block a user