Handle chunked response bodies

adzerk · Jan 9, 2025 · eff8a84 · eff8a84
1 parent 9227ef9
commit eff8a84
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/src/clientFactory.ts b/src/clientFactory.ts
@@ -496,12 +496,14 @@ let handleResponseStream = async <TAcc>({ body, callback, initialValue }: {
   let buffer = Buffer.alloc(0);
 
   return new Promise((resolve, reject) => {
-    let accumulator = initialValue;
-
     if (body !== null) {
-      body.getReader().read().then(({ done, value }) => {
+      let accumulator = initialValue;
+
+      const reader = body.getReader();
+
+      reader.read().then(function processChunk({ done, value }): any {
         if (done) {
-          resolve(accumulator);
+          return resolve(accumulator);
         }
 
         buffer = Buffer.concat([buffer, value]);
@@ -520,6 +522,8 @@ let handleResponseStream = async <TAcc>({ body, callback, initialValue }: {
               return;
             }
           });
+
+          return reader.read().then(processChunk);
       }).catch(e => {
         reject(e);
       })