From 73f66b9638c33b17b743b96e42d2b5c2d4016c24 Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Thu, 16 May 2019 15:00:12 +0100 Subject: [PATCH] Simplify (?) ws.recv invocation --- syndicate/mini/core.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/syndicate/mini/core.py b/syndicate/mini/core.py index 12a770f..c0d8156 100644 --- a/syndicate/mini/core.py +++ b/syndicate/mini/core.py @@ -250,7 +250,7 @@ class WebsocketConnection(Connection): self._on_connected() try: while True: - chunk = await loop.create_task(ws.recv()) + chunk = await ws.recv() self._on_event(protocol.Decoder(chunk).next()) except websockets.exceptions.ConnectionClosed: pass