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