From 9041dbd98ca4f09c1d3f404244471cd675866ebf Mon Sep 17 00:00:00 2001 From: Rafal Makagon Date: Wed, 30 Oct 2019 15:42:03 +0100 Subject: [PATCH] Increase size that is to be read at once from reader's buffer --- src/galaxy/reader.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/galaxy/reader.py b/src/galaxy/reader.py index 551f803..732e658 100644 --- a/src/galaxy/reader.py +++ b/src/galaxy/reader.py @@ -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