Merge pull request #23 from sfriesel/long-test

Thanks Stefan, good stuff! Check out https://www.npmjs.com/package/tape#terrorerr-msg

Author: regular

package.json

@@ -14,7 +14,7 @@
   "scripts": {
     "prepare": "mkdir -p dist && browserify -s unbzip2Stream index.js | uglifyjs > dist/unbzip2-stream.min.js",
     "browser-test": "browserify -t brfs test/simple.js | tape-run",
-    "prepare-long-test": "dd if=/dev/urandom of=test/fixtures/vmlinux.bin bs=50x1024x1024 count=2 && cat test/fixtures/vmlinux.bin | bzip2 > test/fixtures/vmlinux.bin.bz2",
+    "prepare-long-test": "head -c 104857600 < /dev/urandom | tee test/fixtures/vmlinux.bin | bzip2 > test/fixtures/vmlinux.bin.bz2",
     "long-test": "tape test/extra/long.js",
     "download-test": "beefy test/browser/long.js --open -- -t brfs",
     "test": "tape test/*.js"
@@ -38,9 +38,9 @@
     "brfs": "^1.2.0",
     "browserify": "^8.1.0",
     "concat-stream": "^1.4.7",
+    "stream-equal": "^1.1.1",
     "tape": "^3.4.0",
     "tape-run": "^4.0.0",
-    "throughout": "0.0.0",
     "uglify-js": "^3.0.10"
   },
   "dependencies": {

test/extra/long.js

@@ -1,30 +1,17 @@
 var unbzip2Stream = require('../..');
 var test = require('tape');
-var through = require('through');
-var throughout = require('throughout');
 var fs = require('fs');
+var streamEqual = require('stream-equal');
 
 test('a very large binary file piped into unbzip2-stream results in original file content', function(t) {
-    t.plan(2);
+    t.plan(1);
     var source = fs.createReadStream('test/fixtures/vmlinux.bin.bz2');
+    var expected = fs.createReadStream('test/fixtures/vmlinux.bin');
     var unbz2 = unbzip2Stream();
-    var received = 0;
-    var buffers = [];
-    
-    unbz2.on('error', function(err) {
-        console.log(err);
-        //t.notOk(err.message);
+    source.pipe(unbz2);
+    streamEqual(expected, unbz2, function(err, equal) {
+        if (err)
+            t.ok(false, err);
+        t.ok(equal, "same file contents");
     });
-    
-    var sink = through( function write(data) {
-        received += data.length;
-        buffers.push(data);
-    }, function end() {
-        var expected = fs.readFileSync('test/fixtures/vmlinux.bin');
-        t.equal(received, expected.length);
-        t.deepEqual(Buffer.concat(buffers), expected);
-        this.queue(null);
-    });
-    source.pipe(throughout(unbz2,sink));
 });
-