fix request stream body

minio · May 15, 2023 · 286a121 · 286a121
1 parent 7c5eb0d
commit 286a121
Showing 1 changed file with 13 additions and 14 deletions.
diff --git a/src/internal/request.ts b/src/internal/request.ts
@@ -13,22 +13,21 @@ export async function request(
       resolve(resp)
     })
 
-    requestObj.on('error', (e: unknown) => {
-      reject(e)
-    })
-
-    if (body) {
-      if (!Buffer.isBuffer(body) && typeof body !== 'string') {
-        pipeline(body, requestObj, (err) => {
-          if (err) {
-            reject(err)
-          }
+    if (!body || Buffer.isBuffer(body) || typeof body === 'string') {
+      requestObj
+        .on('error', (e: unknown) => {
+          reject(e)
         })
-      } else {
-        requestObj.write(body)
-      }
+        .end(body)
+
+      return
     }
 
-    requestObj.end()
+    // pump readable stream
+    pipeline(body, requestObj, (err) => {
+      if (err) {
+        reject(err)
+      }
+    })
   })
 }