PATH:
usr
/
lib
/
node_modules
/
forever
/
node_modules
/
event-stream
/
test
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)
[-] connect.asynct.js
[edit]
[-] spec.asynct.js
[edit]
[-] readable.asynct.js
[edit]
[-] merge.asynct.js
[edit]
[-] writeArray.asynct.js
[edit]
[-] parse.asynct.js
[edit]
[+]
helper
[-] replace.asynct.js
[edit]
[-] split.asynct.js
[edit]
[+]
..
[-] stringify.js
[edit]
[-] pause.asynct.js
[edit]
[-] simple-map.asynct.js
[edit]
[-] pipeline.asynct.js
[edit]
[-] readArray.asynct.js
[edit]