(source)
| 1806 | Array.prototype.slice.call(arguments).forEach(add); |
| 1807 | return output; |
| 1808 | function add(source) { |
| 1809 | if (Array.isArray(source)) { |
| 1810 | source.forEach(add); |
| 1811 | return this; |
| 1812 | } |
| 1813 | sources.push(source); |
| 1814 | source.once("end", remove.bind(null, source)); |
| 1815 | source.once("error", output.emit.bind(output, "error")); |
| 1816 | source.pipe(output, { end: false }); |
| 1817 | return this; |
| 1818 | } |
| 1819 | function isEmpty() { |
| 1820 | return sources.length == 0; |
| 1821 | } |