diff --git a/test/express-integration.js b/test/express-integration.js
index 34b169bb..10ffb53c 100644
--- a/test/express-integration.js
+++ b/test/express-integration.js
@@ -21,33 +21,47 @@ describe('Express Integration', function () {
     var routeCalled = 0
     var errorCalled = 0
 
-    form.append('avatar', util.file('small1.dat'))
+    form.append('avatar', util.file('large.jpg'))
 
     app.post('/profile', upload.single('avatar'), function (req, res, next) {
       routeCalled++
-      res.status(200).end('')
+      res.status(200).end('SUCCESS')
     })
 
     app.use(function (err, req, res, next) {
       assert.equal(err.code, 'LIMIT_FILE_SIZE')
 
       errorCalled++
-      res.status(500).end('')
+      res.status(500).end('ERROR')
     })
 
     app.listen(port, function () {
-      form.submit('http://localhost:' + port + '/profile', function (err, res) {
-        assert.ifError(err)
+      var res, body
+      var req = form.submit('http://localhost:' + port + '/profile')
+      var pending = 2
 
-        res.pipe(concat({ encoding: 'buffer' }, function (body) {
-          assert.equal(routeCalled, 0)
-          assert.equal(errorCalled, 1)
-          assert.equal(body.length, 0)
-          assert.equal(res.statusCode, 500)
+      function validate () {
+        assert.equal(routeCalled, 0)
+        assert.equal(errorCalled, 1)
+        assert.equal(body.toString(), 'ERROR')
+        assert.equal(res.statusCode, 500)
 
-          done()
+        done()
+      }
+
+      req.on('response', function (_res) {
+        res = _res
+
+        res.pipe(concat({ encoding: 'buffer' }, function (_body) {
+          body = _body
+
+          if (--pending === 0) validate()
         }))
       })
+
+      req.on('finish', function () {
+        if (--pending === 0) validate()
+      })
     })
   })
 })