diff options
Diffstat (limited to 'lib/pull-many-v2.js')
| -rw-r--r-- | lib/pull-many-v2.js | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/lib/pull-many-v2.js b/lib/pull-many-v2.js index beea621..feb68ce 100644 --- a/lib/pull-many-v2.js +++ b/lib/pull-many-v2.js @@ -1,5 +1,6 @@ // All credit to https://github.com/pull-stream/pull-many/blob/master/index.js -// Edits have been made to distinguish the original stream that each object came from +// Edits have been made to distinguish the original stream that each object came from, +// and to be able to end each stream independently module.exports = function (ary) { @@ -59,7 +60,13 @@ module.exports = function (ary) { current.ready = true current.reading = false - if(end === true || abort) current.ended = true + if(end === true || abort) { + current.ended = true + if(current.read.streamName) { + var timestamp = new Date(); + console.log("[pull-many-v2] [" + timestamp.toISOString() + "] " + "reached the end of stream " + current.read.streamName); + } + } else if(end) abort = current.ended = end //check whether we need to abort this stream. if(abort && !end) current.read(abort, next) @@ -90,6 +97,8 @@ module.exports = function (ary) { read.cap = function (err) { read.add(null) } + + read.inputs = inputs return read } |