pumpify
Advanced tools
Comparing version 1.0.0 to 1.0.1
19
index.js
var pump = require('pump') | ||
var duplexify = require('duplexify') | ||
var Foo = function(proxy) { | ||
this._proxy = proxy | ||
} | ||
Foo.prototype._e | ||
var pumpifier = function(duplex) { | ||
@@ -11,9 +17,14 @@ return function() { | ||
var dup = duplex() | ||
var w = first.writable ? first : null | ||
var r = last.readable ? last : null | ||
dup.setWritable(first.writable ? first : null) | ||
dup.setReadable(last.readable ? last : null) | ||
dup.setWritable(w) | ||
dup.setReadable(r) | ||
var onclose = function() { | ||
if (!first.writable && first.destroy) first.destroy() | ||
if (!last.readable && last.destroy) last.destroy() | ||
for (var i = 0; i < streams.length; i++) { | ||
if (!streams[i].destroy) continue; | ||
// we only need to destroy one. pump will care of the others | ||
if (streams[i] !== r && streams[i] !== w) streams[i].destroy() | ||
} | ||
} | ||
@@ -20,0 +31,0 @@ |
{ | ||
"name": "pumpify", | ||
"version": "1.0.0", | ||
"version": "1.0.1", | ||
"description": "Combine an array of streams into a single duplex stream using pump and duplexify", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
4567
92