summaryrefslogtreecommitdiff
path: root/searx/network/__init__.py
diff options
context:
space:
mode:
Diffstat (limited to 'searx/network/__init__.py')
-rw-r--r--searx/network/__init__.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/searx/network/__init__.py b/searx/network/__init__.py
index c921bdec..aaebb792 100644
--- a/searx/network/__init__.py
+++ b/searx/network/__init__.py
@@ -165,7 +165,9 @@ async def stream_chunk_to_queue(network, queue, method, url, **kwargs):
try:
async with network.stream(method, url, **kwargs) as response:
queue.put(response)
- async for chunk in response.aiter_bytes(65536):
+ # aiter_raw: access the raw bytes on the response without applying any HTTP content decoding
+ # https://www.python-httpx.org/quickstart/#streaming-responses
+ async for chunk in response.aiter_raw(65536):
if len(chunk) > 0:
queue.put(chunk)
except (httpx.HTTPError, OSError, h2.exceptions.ProtocolError) as e: