merge.asynct.js 545 B

123456789101112131415161718192021
  1. var es = require('../')
  2. , it = require('it-is').style('colour')
  3. , d = require('ubelt')
  4. exports.merge = function (t) {
  5. var odd = d.map(1, 3, 100, d.id) //array of multiples of 3 < 100
  6. var even = d.map(2, 4, 100, d.id) //array of multiples of 3 < 100
  7. var r1 = es.readArray(even)
  8. var r2 = es.readArray(odd)
  9. var writer = es.writeArray(function (err, array){
  10. if(err) throw err //unpossible
  11. it(array.sort()).deepEqual(even.concat(odd).sort())
  12. t.done()
  13. })
  14. es.merge(r1, r2).pipe(writer)
  15. }
  16. require('./helper')(module)