Increase size that is to be read at once from reader's buffer

This commit is contained in:
Rafal Makagon
2019-10-30 15:42:03 +01:00
parent e57ecc489c
commit 9041dbd98c

View File

@@ -12,7 +12,7 @@ class StreamLineReader:
while True:
# check if there is no unprocessed data in the buffer
if not self._buffer or self._processed_buffer_it != 0:
chunk = await self._reader.read(1024)
chunk = await self._reader.read(1024*1024)
if not chunk:
return bytes() # EOF
self._buffer += chunk