Prevent hanging when stream is not readable

closes stream-utils#57
closes stream-utils#58

HISTORY.md

@@ -2,6 +2,7 @@ unreleased
 ==========
 
   * Prevent loss of async hooks context
+  * Prevent hanging when stream is not readable
   * deps: http-errors@2.0.0
     - deps: depd@2.0.0
     - deps: statuses@2.0.1

README.md

@@ -111,6 +111,10 @@ This error will occur when the given stream has an encoding set on it, making it
 a decoded stream. The stream should not have an encoding set and is expected to
 emit `Buffer` objects.
 
+#### stream.not.readable
+
+This error will occur when the given stream is not readable.
+
 ## Examples
 
 ### Simple Express example

index.js

@@ -174,6 +174,12 @@ function readStream (stream, encoding, length, limit, callback) {
     }))
   }
 
+  if (typeof stream.readable !== 'undefined' && !stream.readable) {
+    return done(createError(500, 'stream is not readable', {
+      type: 'stream.not.readable'
+    }))
+  }
+
   var received = 0
   var decoder
 

test/http.js

@@ -67,6 +67,46 @@ describe('using http streams', function () {
     })
   })
 
+  it('should throw if stream is not readable', function (done) {
+    var server = http.createServer(function onRequest (req, res) {
+      getRawBody(req, { length: req.headers['content-length'] }, function (err) {
+        if (err) {
+          req.resume()
+          res.statusCode = 500
+          res.end(err.message)
+          return
+        }
+
+        getRawBody(req, { length: req.headers['content-length'] }, function (err) {
+          if (err) {
+            res.statusCode = 500
+            res.end('[' + err.type + '] ' + err.message)
+          } else {
+            res.statusCode = 200
+            res.end()
+          }
+        })
+      })
+    })
+
+    server.listen(function onListen () {
+      var addr = server.address()
+      var client = http.request({ method: 'POST', port: addr.port })
+
+      client.end('hello, world!')
+
+      client.on('response', function onResponse (res) {
+        getRawBody(res, { encoding: true }, function (err, str) {
+          server.close(function onClose () {
+            assert.ifError(err)
+            assert.strictEqual(str, '[stream.not.readable] stream is not readable')
+            done()
+          })
+        })
+      })
+    })
+  })
+
   it('should throw if connection ends', function (done) {
     var socket
     var server = http.createServer(function onRequest (req, res) {