Comparing version 2.2.1 to 2.2.2
{ | ||
"name": "through", | ||
"version": "2.2.1", | ||
"version": "2.2.2", | ||
"description": "simplified stream contruction", | ||
"main": "index.js", | ||
"scripts": { | ||
"test": "asynct test/*.js" | ||
"test": "set -e; for t in test/*.js; do node $t; done" | ||
}, | ||
"devDependencies": { | ||
"stream-spec": "0", | ||
"assertions": "2", | ||
"asynct":"1" | ||
"stream-spec": "~0.3.2", | ||
"tape": "~0.2.2" | ||
}, | ||
@@ -23,6 +22,15 @@ "keywords": [ | ||
"repository": { | ||
"type":"git", | ||
"type": "git", | ||
"url": "https://github.com/dominictarr/through.git" | ||
}, | ||
"homepage": "http://github.com/dominictarr/through" | ||
"homepage": "http://github.com/dominictarr/through", | ||
"testling": { | ||
"browsers": [ | ||
"ie/6..latest", | ||
"ff/3.6..latest", | ||
"chrome/4..latest", | ||
"safari/5.1..latest" | ||
], | ||
"files": "test/*.js" | ||
} | ||
} |
@@ -0,1 +1,2 @@ | ||
var test = require('tape') | ||
var through = require('..') | ||
@@ -5,3 +6,3 @@ | ||
exports['buffering'] = function (t) { | ||
test('buffering', function(assert) { | ||
var ts = through(function (data) { | ||
@@ -23,3 +24,3 @@ this.queue(data) | ||
ts.write(3) | ||
t.deepEqual(actual, [1, 2, 3]) | ||
assert.deepEqual(actual, [1, 2, 3]) | ||
ts.pause() | ||
@@ -29,16 +30,15 @@ ts.write(4) | ||
ts.write(6) | ||
t.deepEqual(actual, [1, 2, 3]) | ||
assert.deepEqual(actual, [1, 2, 3]) | ||
ts.resume() | ||
t.deepEqual(actual, [1, 2, 3, 4, 5, 6]) | ||
assert.deepEqual(actual, [1, 2, 3, 4, 5, 6]) | ||
ts.pause() | ||
ts.end() | ||
t.ok(!ended) | ||
assert.ok(!ended) | ||
ts.resume() | ||
t.ok(ended) | ||
t.end() | ||
assert.ok(ended) | ||
assert.end() | ||
}) | ||
} | ||
test('buffering has data in queue, when ends', function (assert) { | ||
exports['buffering has data in queue, when ends'] = function (t) { | ||
/* | ||
@@ -68,8 +68,8 @@ * If stream ends while paused with data in the queue, | ||
ts.end() | ||
t.deepEqual(actual, [], 'no data written yet, still paused') | ||
t.ok(!ended, 'end not emitted yet, still paused') | ||
assert.deepEqual(actual, [], 'no data written yet, still paused') | ||
assert.ok(!ended, 'end not emitted yet, still paused') | ||
ts.resume() | ||
t.deepEqual(actual, [1, 2, 3], 'resumed, all data should be delivered') | ||
t.ok(ended, 'end should be emitted once all data was delivered') | ||
t.end(); | ||
} | ||
assert.deepEqual(actual, [1, 2, 3], 'resumed, all data should be delivered') | ||
assert.ok(ended, 'end should be emitted once all data was delivered') | ||
assert.end(); | ||
}) |
@@ -0,1 +1,2 @@ | ||
var test = require('tape') | ||
var through = require('..') | ||
@@ -5,3 +6,3 @@ | ||
exports['end before close'] = function (t) { | ||
test('end before close', function (assert) { | ||
var ts = through() | ||
@@ -11,7 +12,7 @@ var ended = false, closed = false | ||
ts.on('end', function () { | ||
t.ok(!closed) | ||
assert.ok(!closed) | ||
ended = true | ||
}) | ||
ts.on('close', function () { | ||
t.ok(ended) | ||
assert.ok(ended) | ||
closed = true | ||
@@ -24,7 +25,5 @@ }) | ||
ts.end() | ||
t.ok(ended) | ||
t.ok(closed) | ||
t.end() | ||
} | ||
assert.ok(ended) | ||
assert.ok(closed) | ||
assert.end() | ||
}) |
var test = require('tape') | ||
var spec = require('stream-spec') | ||
var through = require('..') | ||
var a = require('assertions') | ||
@@ -38,10 +38,10 @@ /* | ||
exports['simple defaults'] = function (test) { | ||
test('simple defaults', function(assert) { | ||
var l = 1000 | ||
, expected = [] | ||
, expected = [] | ||
while(l--) expected.push(l * Math.random()) | ||
var t = through() | ||
var t = through() | ||
spec(t) | ||
@@ -53,11 +53,11 @@ .through() | ||
read(t, function (err, actual) { | ||
if(err) test.error(err) //fail | ||
a.deepEqual(actual, expected) | ||
test.done() | ||
assert.ifError(err) | ||
assert.deepEqual(actual, expected) | ||
assert.end() | ||
}) | ||
write(expected, t) | ||
} | ||
}); | ||
exports['simple functions'] = function (test) { | ||
test('simple functions', function(assert) { | ||
@@ -78,13 +78,14 @@ var l = 1000 | ||
read(t, function (err, actual) { | ||
if(err) test.error(err) //fail | ||
a.deepEqual(actual, expected.map(function (data) { | ||
assert.ifError(err) | ||
assert.deepEqual(actual, expected.map(function (data) { | ||
return data*2 | ||
})) | ||
test.done() | ||
assert.end() | ||
}) | ||
write(expected, t) | ||
} | ||
exports['pauses'] = function (test) { | ||
}) | ||
test('pauses', function(assert) { | ||
var l = 1000 | ||
@@ -110,8 +111,8 @@ , expected = [] | ||
read(t, function (err, actual) { | ||
if(err) test.error(err) //fail | ||
a.deepEqual(actual, expected) | ||
test.done() | ||
assert.ifError(err) | ||
assert.deepEqual(actual, expected) | ||
assert.end() | ||
}) | ||
write(expected, t) | ||
} | ||
}) |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
9983
2
257