fix(upload): should a single chunk if the stream is equal to partsize

aws · Aug 1, 2023 · 4be0a19 · 4be0a19
1 parent 84ee148
commit 4be0a19
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/lib/lib-storage/src/chunks/getChunkStream.ts b/lib/lib-storage/src/chunks/getChunkStream.ts
@@ -19,7 +19,7 @@ export async function* getChunkStream<T>(
     currentBuffer.chunks.push(datum);
     currentBuffer.length += datum.length;
 
-    while (currentBuffer.length >= partSize) {
+    while (currentBuffer.length > partSize) {
       /**
        * Concat all the buffers together once if there is more than one to concat. Attempt
        * to minimize concats as Buffer.Concat is an extremely expensive operation.

diff --git a/lib/lib-storage/src/chunks/getDataReadableStream.spec.ts b/lib/lib-storage/src/chunks/getDataReadableStream.spec.ts
@@ -44,6 +44,15 @@ describe("chunkFromReadable.name", () => {
     expect(chunks[0].lastPart).toBe(true);
   });
 
+  it("should a single chunk if the stream is equal to partsize", async () => {
+    const chunks = await getChunks(20, 5, 100);
+
+    expect(chunks.length).toBe(1);
+    expect(byteLength(chunks[0].data)).toEqual(100);
+    expect(chunks[0].partNumber).toEqual(1);
+    expect(chunks[0].lastPart).toBe(true);
+  });
+
   it("should return chunks of a specific size", async () => {
     const chunks = await getChunks(58, 1, 20);