Fixes chunk method not properly awaiting (#305)

parcelvoy · Oct 31, 2023 · 3a5fac6 · 3a5fac6
1 parent 2e7d15f
commit 3a5fac6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/apps/platform/src/utilities/index.ts b/apps/platform/src/utilities/index.ts
@@ -217,7 +217,7 @@ export const chunk = async <T>(
     const chunker = new Chunker(callback, size)
     await query.stream(async function(stream) {
         for await (const result of stream) {
-            chunker.add(modifier(result))
+            await chunker.add(modifier(result))
         }
     })
     await chunker.flush()