|
@ -45,8 +45,8 @@ function run() { |
|
|
var fn = next[1]; |
|
|
var fn = next[1]; |
|
|
console.log('# %s', name); |
|
|
console.log('# %s', name); |
|
|
fn({ |
|
|
fn({ |
|
|
same: assert.deepEqual, |
|
|
same: assert.deepStrictEqual, |
|
|
equal: assert.equal, |
|
|
equal: assert.strictEqual, |
|
|
end: function() { |
|
|
end: function() { |
|
|
count--; |
|
|
count--; |
|
|
run(); |
|
|
run(); |
|
@ -56,7 +56,7 @@ function run() { |
|
|
|
|
|
|
|
|
// ensure all tests have run
|
|
|
// ensure all tests have run
|
|
|
process.on('exit', function() { |
|
|
process.on('exit', function() { |
|
|
assert.equal(count, 0); |
|
|
assert.strictEqual(count, 0); |
|
|
}); |
|
|
}); |
|
|
|
|
|
|
|
|
process.nextTick(run); |
|
|
process.nextTick(run); |
|
@ -136,17 +136,17 @@ test('write bufferize', function(t) { |
|
|
}); |
|
|
}); |
|
|
|
|
|
|
|
|
var encodings = |
|
|
var encodings = |
|
|
[ 'hex', |
|
|
[ 'hex', |
|
|
'utf8', |
|
|
'utf8', |
|
|
'utf-8', |
|
|
'utf-8', |
|
|
'ascii', |
|
|
'ascii', |
|
|
'binary', |
|
|
'binary', |
|
|
'base64', |
|
|
'base64', |
|
|
'ucs2', |
|
|
'ucs2', |
|
|
'ucs-2', |
|
|
'ucs-2', |
|
|
'utf16le', |
|
|
'utf16le', |
|
|
'utf-16le', |
|
|
'utf-16le', |
|
|
undefined ]; |
|
|
undefined ]; |
|
|
|
|
|
|
|
|
tw.on('finish', function() { |
|
|
tw.on('finish', function() { |
|
|
t.same(tw.buffer, chunks, 'got the expected chunks'); |
|
|
t.same(tw.buffer, chunks, 'got the expected chunks'); |
|
@ -173,17 +173,17 @@ test('write no bufferize', function(t) { |
|
|
}; |
|
|
}; |
|
|
|
|
|
|
|
|
var encodings = |
|
|
var encodings = |
|
|
[ 'hex', |
|
|
[ 'hex', |
|
|
'utf8', |
|
|
'utf8', |
|
|
'utf-8', |
|
|
'utf-8', |
|
|
'ascii', |
|
|
'ascii', |
|
|
'binary', |
|
|
'binary', |
|
|
'base64', |
|
|
'base64', |
|
|
'ucs2', |
|
|
'ucs2', |
|
|
'ucs-2', |
|
|
'ucs-2', |
|
|
'utf16le', |
|
|
'utf16le', |
|
|
'utf-16le', |
|
|
'utf-16le', |
|
|
undefined ]; |
|
|
undefined ]; |
|
|
|
|
|
|
|
|
tw.on('finish', function() { |
|
|
tw.on('finish', function() { |
|
|
t.same(tw.buffer, chunks, 'got the expected chunks'); |
|
|
t.same(tw.buffer, chunks, 'got the expected chunks'); |
|
@ -199,7 +199,7 @@ test('write no bufferize', function(t) { |
|
|
|
|
|
|
|
|
test('write callbacks', function(t) { |
|
|
test('write callbacks', function(t) { |
|
|
var callbacks = chunks.map(function(chunk, i) { |
|
|
var callbacks = chunks.map(function(chunk, i) { |
|
|
return [i, function(er) { |
|
|
return [i, function() { |
|
|
callbacks._called[i] = chunk; |
|
|
callbacks._called[i] = chunk; |
|
|
}]; |
|
|
}]; |
|
|
}).reduce(function(set, x) { |
|
|
}).reduce(function(set, x) { |
|
@ -270,7 +270,7 @@ test('end callback called after write callback', function(t) { |
|
|
test('encoding should be ignored for buffers', function(t) { |
|
|
test('encoding should be ignored for buffers', function(t) { |
|
|
var tw = new W(); |
|
|
var tw = new W(); |
|
|
var hex = '018b5e9a8f6236ffe30e31baf80d2cf6eb'; |
|
|
var hex = '018b5e9a8f6236ffe30e31baf80d2cf6eb'; |
|
|
tw._write = function(chunk, encoding, cb) { |
|
|
tw._write = function(chunk) { |
|
|
t.equal(chunk.toString('hex'), hex); |
|
|
t.equal(chunk.toString('hex'), hex); |
|
|
t.end(); |
|
|
t.end(); |
|
|
}; |
|
|
}; |
|
@ -282,7 +282,7 @@ test('writables are not pipable', function(t) { |
|
|
var w = new W(); |
|
|
var w = new W(); |
|
|
w._write = function() {}; |
|
|
w._write = function() {}; |
|
|
var gotError = false; |
|
|
var gotError = false; |
|
|
w.on('error', function(er) { |
|
|
w.on('error', function() { |
|
|
gotError = true; |
|
|
gotError = true; |
|
|
}); |
|
|
}); |
|
|
w.pipe(process.stdout); |
|
|
w.pipe(process.stdout); |
|
@ -295,7 +295,7 @@ test('duplexes are pipable', function(t) { |
|
|
d._read = function() {}; |
|
|
d._read = function() {}; |
|
|
d._write = function() {}; |
|
|
d._write = function() {}; |
|
|
var gotError = false; |
|
|
var gotError = false; |
|
|
d.on('error', function(er) { |
|
|
d.on('error', function() { |
|
|
gotError = true; |
|
|
gotError = true; |
|
|
}); |
|
|
}); |
|
|
d.pipe(process.stdout); |
|
|
d.pipe(process.stdout); |
|
@ -329,7 +329,7 @@ test('dont end while writing', function(t) { |
|
|
setTimeout(function() { |
|
|
setTimeout(function() { |
|
|
this.writing = false; |
|
|
this.writing = false; |
|
|
cb(); |
|
|
cb(); |
|
|
}); |
|
|
}, 1); |
|
|
}; |
|
|
}; |
|
|
w.on('finish', function() { |
|
|
w.on('finish', function() { |
|
|
assert(wrote); |
|
|
assert(wrote); |
|
@ -366,7 +366,7 @@ test('finish does not come before sync _write cb', function(t) { |
|
|
assert(writeCb); |
|
|
assert(writeCb); |
|
|
t.end(); |
|
|
t.end(); |
|
|
}); |
|
|
}); |
|
|
w.write(Buffer(0), function(er) { |
|
|
w.write(Buffer.alloc(0), function() { |
|
|
writeCb = true; |
|
|
writeCb = true; |
|
|
}); |
|
|
}); |
|
|
w.end(); |
|
|
w.end(); |
|
|