writeblob

Author: Uzlopak

lib/dispatcher/client-h1.js

@@ -1369,33 +1369,29 @@ function writeBuffer (abort, body, client, request, socket, contentLength, heade
 function writeBlob (abort, body, client, request, socket, contentLength, header, expectsPayload) {
   assert(contentLength === body.size, 'blob body must have content length')
 
-  try {
-    if (contentLength != null && contentLength !== body.size) {
-      throw new RequestContentLengthMismatchError()
-    }
-
-    body.arrayBuffer().then(arrayBuffer => {
-      const buffer = Buffer.from(arrayBuffer)
+  if (contentLength != null && contentLength !== body.size) {
+    abort(new RequestContentLengthMismatchError())
+    return
+  }
+  body.arrayBuffer().then(arrayBuffer => {
+    const buffer = Buffer.from(arrayBuffer)
 
-      socket.cork()
-      socket.write(`${header}content-length: ${contentLength}\r\n\r\n`, 'latin1')
-      socket.write(buffer)
-      socket.uncork()
+    socket.cork()
+    socket.write(`${header}content-length: ${contentLength}\r\n\r\n`, 'latin1')
+    socket.write(buffer)
+    socket.uncork()
 
-      request.onBodySent(buffer)
-      request.onRequestSent()
+    request.onBodySent(buffer)
+    request.onRequestSent()
 
-      if (!expectsPayload && request.reset !== false) {
-        socket[kReset] = true
-      }
+    if (!expectsPayload && request.reset !== false) {
+      socket[kReset] = true
+    }
 
-      client[kResume]()
-    }).catch(err => {
-      abort(err)
-    })
-  } catch (err) {
+    client[kResume]()
+  }).catch(err => {
     abort(err)
-  }
+  })
 }
 
 /**

lib/dispatcher/client-h2.js

@@ -732,31 +732,26 @@ function writeStream (abort, socket, expectsPayload, h2stream, body, client, req
 function writeBlob (abort, h2stream, body, client, request, socket, contentLength, expectsPayload) {
   assert(contentLength === body.size, 'blob body must have content length')
 
-  try {
-    if (contentLength != null && contentLength !== body.size) {
-      throw new RequestContentLengthMismatchError()
-    }
-
-    body.arrayBuffer().then(arrayBuffer => {
-      const buffer = Buffer.from(arrayBuffer)
+  if (contentLength != null && contentLength !== body.size) {
+    abort(new RequestContentLengthMismatchError())
+  }
+  body.arrayBuffer().then(arrayBuffer => {
+    const buffer = Buffer.from(arrayBuffer)
 
-      h2stream.cork()
-      h2stream.write(buffer)
-      h2stream.uncork()
-      h2stream.end()
+    h2stream.cork()
+    h2stream.write(buffer)
+    h2stream.uncork()
+    h2stream.end()
 
-      request.onBodySent(buffer)
-      request.onRequestSent()
+    request.onBodySent(buffer)
+    request.onRequestSent()
 
-      if (!expectsPayload) {
-        socket[kReset] = true
-      }
+    if (!expectsPayload) {
+      socket[kReset] = true
+    }
 
-      client[kResume]()
-    }).catch(err => abort(err))
-  } catch (err) {
-    abort(err)
-  }
+    client[kResume]()
+  }).catch(err => abort(err))
 }
 
 async function writeIterable (abort, h2stream, body, client, request, socket, contentLength, expectsPayload) {