diff --git a/trio_websocket/_impl.py b/trio_websocket/_impl.py
index 259f4fd..2aa0e32 100644
--- a/trio_websocket/_impl.py
+++ b/trio_websocket/_impl.py
@@ -38,7 +38,6 @@
 CONN_TIMEOUT = 60 # default connect & disconnect timeout, in seconds
 MESSAGE_QUEUE_SIZE = 1
 MAX_MESSAGE_SIZE = 2 ** 20 # 1 MiB
-RECEIVE_BYTES = 4 * 2 ** 10 # 4 KiB
 logger = logging.getLogger('trio-websocket')
 
 
@@ -1232,7 +1231,7 @@ async def _reader_task(self):
 
                 # Get network data.
                 try:
-                    data = await self._stream.receive_some(RECEIVE_BYTES)
+                    data = await self._stream.receive_some()
                 except (trio.BrokenResourceError, trio.ClosedResourceError):
                     await self._abort_web_socket()
                     break