es.concat - if any stream is ended it doesn't work

[manuelsantillan]

If passing an already ended stream to es.concat / es.merge, it won't work unless an "end" event is manually provoked for that stream.

A possible fix would be to check if there is a "ended" property in the stream object and increment the counter during stream registration:

es.merge = function (/streams.../) {
var toMerge = [].slice.call(arguments)
var stream = new Stream()
var endCount = 0
stream.writable = stream.readable = true

toMerge.forEach(function (e) {

e.pipe(stream, {end: false})
var ended = false
  //BEGIN FIX
if(e.ended) {
    ended=true
    endCount++
}
  //END FIX
e.on('end', function () {

    if(ended) return
  ended = true
  endCount ++
  if(endCount == toMerge.length)
    stream.emit('end') 
})

})
stream.write = function (data) {
this.emit('data', data)
}
stream.destroy = function () {
merge.forEach(function (e) {
if(e.destroy) e.destroy()
})
}
return stream
}

[dominictarr]

There is no standand way to indicate that a stream has already ended, so it's unlikely this patch would work in general.

How are you getting streams that have already ended?
prehaps there is another approach to your problem.
can you explain/post code that shows what you are trying to do?