Fix offset overflow in multipart download (#871)

monix · Mar 23, 2022 · a089f55 · a089f55
1 parent 84e2427
commit a089f55
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/s3/src/main/scala/monix/connect/s3/MultipartDownloadObservable.scala b/s3/src/main/scala/monix/connect/s3/MultipartDownloadObservable.scala
@@ -64,7 +64,7 @@ private[s3] class MultipartDownloadObservable(
     totalSize: Long,
     chunkSize: Long,
     getRequest: GetObjectRequest,
-    offset: Int): Task[Unit] = {
+    offset: Long): Task[Unit] = {
 
     for {
       chunk <- {
@@ -77,7 +77,7 @@ private[s3] class MultipartDownloadObservable(
       nextChunk <- {
         ack match {
           case Ack.Continue => {
-            val nextOffset = offset + chunk.size
+            val nextOffset = offset + chunk.length
             if (nextOffset < totalSize) {
               val nextRange = s"bytes=${nextOffset}-${nextOffset + chunkSize}"
               val nextRequest = getRequest.toBuilder.range(nextRange).build()