diff --git a/fsspec/implementations/http.py b/fsspec/implementations/http.py index a64942e22..36164864c 100644 --- a/fsspec/implementations/http.py +++ b/fsspec/implementations/http.py @@ -274,11 +274,11 @@ async def gen_chunks(): else: callback.set_size(getattr(f, "size", None)) - chunk = f.read(64 * 1024) + chunk = f.read(chunk_size) while chunk: yield chunk callback.relative_update(len(chunk)) - chunk = f.read(64 * 1024) + chunk = f.read(chunk_size) kw = self.kwargs.copy() kw.update(kwargs)