aboutsummaryrefslogtreecommitdiff
path: root/node_modules/stream-consume/index.js
diff options
context:
space:
mode:
Diffstat (limited to 'node_modules/stream-consume/index.js')
-rw-r--r--node_modules/stream-consume/index.js14
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
+ }
+ }
+ }
+};