Simplify (?) ws.recv invocation
This commit is contained in:
parent
d514baac38
commit
73f66b9638
|
@ -250,7 +250,7 @@ class WebsocketConnection(Connection):
|
||||||
self._on_connected()
|
self._on_connected()
|
||||||
try:
|
try:
|
||||||
while True:
|
while True:
|
||||||
chunk = await loop.create_task(ws.recv())
|
chunk = await ws.recv()
|
||||||
self._on_event(protocol.Decoder(chunk).next())
|
self._on_event(protocol.Decoder(chunk).next())
|
||||||
except websockets.exceptions.ConnectionClosed:
|
except websockets.exceptions.ConnectionClosed:
|
||||||
pass
|
pass
|
||||||
|
|
Loading…
Reference in New Issue