diff options
Diffstat (limited to 'node_modules/stream-slice/test.js')
| -rw-r--r-- | node_modules/stream-slice/test.js | 46 |
1 files changed, 46 insertions, 0 deletions
diff --git a/node_modules/stream-slice/test.js b/node_modules/stream-slice/test.js new file mode 100644 index 00000000..e857d2d6 --- /dev/null +++ b/node_modules/stream-slice/test.js @@ -0,0 +1,46 @@ + +var test = require('tape'); +var fs = require('fs'); +var slice = require('./index').slice; +var bufferReady = fs.readFileSync('./README.md'); + +test('normal test', function(t) { + var chunks = []; + fs.createReadStream('./README.md') + .pipe(slice(0, 10)) + .on('data', chunks.push.bind(chunks)) + .on('end', function() { + var res = Buffer.concat(chunks); + t.equal(res.length, 10); + t.equal(bufferEq(res, bufferReady.slice(0, 10)), true); + t.end(); + }); +}); + +test('normal test', function(t) { + var chunks = []; + fs.createReadStream('./README.md') + .pipe(slice(10, 20)) + .on('data', chunks.push.bind(chunks)) + .on('end', function() { + var res = Buffer.concat(chunks); + t.equal(res.length, 10); + t.equal(bufferEq(res, bufferReady.slice(10, 20)), true); + t.end(); + }); +}); + +function bufferEq(foo, bar) { + if (!Buffer.isBuffer(foo) || !Buffer.isBuffer(bar)) { + throw new TypeError('Arguments must be a buffer'); + } + if (foo.length !== bar.length) { + return false; + } + for (var i = 0; i < foo.length; i++) { + if (foo[i] !== bar[i]) { + return false; + } + } + return true; +}
\ No newline at end of file |
