diff --git a/lib/make-middleware.js b/lib/make-middleware.js index b033cbd9..529c1928 100644 --- a/lib/make-middleware.js +++ b/lib/make-middleware.js @@ -42,10 +42,16 @@ function makeMiddleware (setup) { var pendingWrites = new Counter() var uploadedFiles = [] + function requestError(error) { + if(!busboy) return + busboy.destroy(error) + } + function done (err) { if (isDone) return isDone = true + req.removeListener('error', requestError) req.unpipe(busboy) drainStream(req) busboy.removeAllListeners() @@ -174,6 +180,7 @@ function makeMiddleware (setup) { indicateDone() }) + req.on('error', requestError) req.pipe(busboy) } }