diff options
Diffstat (limited to 'node_modules/stream-consume/index.js')
-rw-r--r-- | node_modules/stream-consume/index.js | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/node_modules/stream-consume/index.js b/node_modules/stream-consume/index.js new file mode 100644 index 000000000..122edb18a --- /dev/null +++ b/node_modules/stream-consume/index.js @@ -0,0 +1,14 @@ +module.exports = function(stream) { + if (stream.readable && typeof stream.resume === 'function') { + var state = stream._readableState; + if (!state || state.pipesCount === 0) { + // Either a classic stream or streams2 that's not piped to another destination + try { + stream.resume(); + } catch (err) { + console.error("Got error: " + err); + // If we can't, it's not worth dying over + } + } + } +}; |