d795301025
common.js needs to be loaded in all tests so that there is checking for variable leaks and possibly other things. However, it does not need to be assigned to a variable if nothing in common.js is referred to elsewhere in the test. The main tradeoff for this bit of code churn is that it gets the code base most of the way to being able to enable the no-unused-vars rule in eslint. (The non-tooling benefit is that it lessens cognitive load when reading tests as it is an immediate indication that none of the functions or properties in common.js will be used by the test.) PR-URL: https://github.com/nodejs/node/pull/4563 Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Ben Noordhuis <info@bnoordhuis.nl>
53 lines
1.5 KiB
JavaScript
53 lines
1.5 KiB
JavaScript
'use strict';
|
|
require('../common');
|
|
var assert = require('assert');
|
|
var util = require('util');
|
|
var stream = require('stream');
|
|
|
|
var passed = false;
|
|
|
|
function PassThrough() {
|
|
stream.Transform.call(this);
|
|
};
|
|
util.inherits(PassThrough, stream.Transform);
|
|
PassThrough.prototype._transform = function(chunk, encoding, done) {
|
|
this.push(chunk);
|
|
done();
|
|
};
|
|
|
|
function TestStream() {
|
|
stream.Transform.call(this);
|
|
};
|
|
util.inherits(TestStream, stream.Transform);
|
|
TestStream.prototype._transform = function(chunk, encoding, done) {
|
|
if (!passed) {
|
|
// Char 'a' only exists in the last write
|
|
passed = chunk.toString().indexOf('a') >= 0;
|
|
}
|
|
done();
|
|
};
|
|
|
|
var s1 = new PassThrough();
|
|
var s2 = new PassThrough();
|
|
var s3 = new TestStream();
|
|
s1.pipe(s3);
|
|
// Don't let s2 auto close which may close s3
|
|
s2.pipe(s3, {end: false});
|
|
|
|
// We must write a buffer larger than highWaterMark
|
|
var big = new Buffer(s1._writableState.highWaterMark + 1);
|
|
big.fill('x');
|
|
|
|
// Since big is larger than highWaterMark, it will be buffered internally.
|
|
assert(!s1.write(big));
|
|
// 'tiny' is small enough to pass through internal buffer.
|
|
assert(s2.write('tiny'));
|
|
|
|
// Write some small data in next IO loop, which will never be written to s3
|
|
// Because 'drain' event is not emitted from s1 and s1 is still paused
|
|
setImmediate(s1.write.bind(s1), 'later');
|
|
|
|
// Assert after two IO loops when all operations have been done.
|
|
process.on('exit', function() {
|
|
assert(passed, 'Large buffer is not handled properly by Writable Stream');
|
|
});
|