index.js
506 Bytes
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
}
}
}
};