diff --git a/sdk/core/azure-core/azure/core/pipeline/transport/aiohttp.py b/sdk/core/azure-core/azure/core/pipeline/transport/aiohttp.py
index bf6b5f2bdc5b..7fb2d191fee4 100644
--- a/sdk/core/azure-core/azure/core/pipeline/transport/aiohttp.py
+++ b/sdk/core/azure-core/azure/core/pipeline/transport/aiohttp.py
@@ -231,14 +231,14 @@ async def __anext__(self):
                     retry_active = False
                 else:
                     await asyncio.sleep(retry_interval)
-                    headers = {'range': 'bytes=' + self.downloaded + '-'}
+                    headers = {'range': 'bytes=' + str(self.downloaded) + '-'}
                     resp = self.pipeline.run(self.request, stream=True, headers=headers)
                     if resp.status_code == 416:
                         raise
                     chunk = await self.response.internal_response.content.read(self.block_size)
                     if not chunk:
                         raise StopIteration()
-                    self.downloaded += chunk
+                    self.downloaded += len(chunk)
                     return chunk
                 continue
             except StreamConsumedError:
diff --git a/sdk/core/azure-core/azure/core/pipeline/transport/requests_asyncio.py b/sdk/core/azure-core/azure/core/pipeline/transport/requests_asyncio.py
index bc3d50d4f04b..2d237d69774f 100644
--- a/sdk/core/azure-core/azure/core/pipeline/transport/requests_asyncio.py
+++ b/sdk/core/azure-core/azure/core/pipeline/transport/requests_asyncio.py
@@ -182,7 +182,7 @@ async def __anext__(self):
                     retry_active = False
                 else:
                     await asyncio.sleep(retry_interval)
-                    headers = {'range': 'bytes=' + self.downloaded + '-'}
+                    headers = {'range': 'bytes=' + str(self.downloaded) + '-'}
                     resp = self.pipeline.run(self.request, stream=True, headers=headers)
                     if resp.status_code == 416:
                         raise
@@ -193,7 +193,7 @@ async def __anext__(self):
                     )
                     if not chunk:
                         raise StopIteration()
-                    self.downloaded += chunk
+                    self.downloaded += len(chunk)
                     return chunk
                 continue
             except requests.exceptions.StreamConsumedError:
diff --git a/sdk/core/azure-core/azure/core/pipeline/transport/requests_basic.py b/sdk/core/azure-core/azure/core/pipeline/transport/requests_basic.py
index 0947c54b7239..9b312be50d0e 100644
--- a/sdk/core/azure-core/azure/core/pipeline/transport/requests_basic.py
+++ b/sdk/core/azure-core/azure/core/pipeline/transport/requests_basic.py
@@ -120,14 +120,14 @@ def __next__(self):
                     retry_active = False
                 else:
                     time.sleep(retry_interval)
-                    headers = {'range': 'bytes=' + self.downloaded + '-'}
+                    headers = {'range': 'bytes=' + str(self.downloaded) + '-'}
                     resp = self.pipeline.run(self.request, stream=True, headers=headers)
                     if resp.status_code == 416:
                         raise
                     chunk = next(self.iter_content_func)
                     if not chunk:
                         raise StopIteration()
-                    self.downloaded += chunk
+                    self.downloaded += len(chunk)
                     return chunk
                 continue
             except requests.exceptions.StreamConsumedError:
diff --git a/sdk/core/azure-core/azure/core/pipeline/transport/requests_trio.py b/sdk/core/azure-core/azure/core/pipeline/transport/requests_trio.py
index 5b52e52dcfa5..9de405697d27 100644
--- a/sdk/core/azure-core/azure/core/pipeline/transport/requests_trio.py
+++ b/sdk/core/azure-core/azure/core/pipeline/transport/requests_trio.py
@@ -98,7 +98,7 @@ async def __anext__(self):
                     retry_active = False
                 else:
                     await trio.sleep(1000)
-                    headers = {'range': 'bytes=' + self.downloaded + '-'}
+                    headers = {'range': 'bytes=' + str(self.downloaded) + '-'}
                     resp = self.pipeline.run(self.request, stream=True, headers=headers)
                     if resp.status_code == 416:
                         raise
@@ -114,7 +114,7 @@ async def __anext__(self):
                         )
                     if not chunk:
                         raise StopIteration()
-                    self.downloaded += chunk
+                    self.downloaded += len(chunk)
                     return chunk
                 continue
             except requests.exceptions.StreamConsumedError: