Edit File: merge.asynct.js
var es = require('../') , it = require('it-is').style('colour') , d = require('ubelt') exports.merge = function (t) { var odd = d.map(1, 3, 100, d.id) //array of multiples of 3 < 100 var even = d.map(2, 4, 100, d.id) //array of multiples of 3 < 100 var r1 = es.readArray(even) var r2 = es.readArray(odd) var endCount = 0 var writer = es.writeArray(function (err, array){ if(err) throw err //unpossible it(array.sort()).deepEqual(even.concat(odd).sort()) if (++endCount === 2) t.done() }) var writer2 = es.writeArray(function (err, array){ if(err) throw err //unpossible it(array.sort()).deepEqual(even.concat(odd).sort()) if (++endCount === 2) t.done() }) es.merge(r1, r2).pipe(writer) es.merge([r1, r2]).pipe(writer2) } require('./helper')(module)
Back to File Manager