X7ROOT File Manager
Current Path:
/lib/node_modules/npm/node_modules/stream-iterate
lib
/
node_modules
/
npm
/
node_modules
/
stream-iterate
/
ðŸ“
..
📄
.npmignore
(13 B)
📄
.travis.yml
(60 B)
📄
LICENSE
(1.05 KB)
📄
README.md
(834 B)
📄
index.js
(1.33 KB)
ðŸ“
node_modules
📄
package.json
(1.49 KB)
📄
test.js
(1.2 KB)
Editing: test.js
var tape = require('tape') var from = require('from2') var iterate = require('./') tape('merge sort', function (t) { var a = from.obj(['a', 'b', 'd', 'e', 'g', 'h']) var b = from.obj(['b', 'c', 'f']) var output = [] var readA = iterate(a) var readB = iterate(b) var loop = function () { readA(function (err, dataA, nextA) { if (err) throw err readB(function (err, dataB, nextB) { if (err) throw err if (!dataA && !dataB) { t.same(output, ['a', 'b', 'b', 'c', 'd', 'e', 'f', 'g', 'h'], 'sorts list') t.end() return } if (!dataB || dataA < dataB) { output.push(dataA) nextA() return loop() } if (!dataA || dataA > dataB) { output.push(dataB) nextB() return loop() } output.push(dataA) output.push(dataB) nextA() nextB() loop() }) }) } loop() }) tape('error handling', function (t) { var a = from.obj(['a', 'b', 'd', 'e', 'g', 'h']) var read = iterate(a) a.destroy(new Error('oh no')) read(function (err) { t.ok(err, 'had error') t.same(err.message, 'oh no') t.end() }) })
Upload File
Create Folder