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>
106 lines
2.3 KiB
JavaScript
106 lines
2.3 KiB
JavaScript
'use strict';
|
|
require('../common');
|
|
var assert = require('assert');
|
|
|
|
var Readable = require('stream').Readable;
|
|
|
|
(function first() {
|
|
// First test, not reading when the readable is added.
|
|
// make sure that on('readable', ...) triggers a readable event.
|
|
var r = new Readable({
|
|
highWaterMark: 3
|
|
});
|
|
|
|
var _readCalled = false;
|
|
r._read = function(n) {
|
|
_readCalled = true;
|
|
};
|
|
|
|
// This triggers a 'readable' event, which is lost.
|
|
r.push(new Buffer('blerg'));
|
|
|
|
var caughtReadable = false;
|
|
setTimeout(function() {
|
|
// we're testing what we think we are
|
|
assert(!r._readableState.reading);
|
|
r.on('readable', function() {
|
|
caughtReadable = true;
|
|
});
|
|
});
|
|
|
|
process.on('exit', function() {
|
|
// we're testing what we think we are
|
|
assert(!_readCalled);
|
|
|
|
assert(caughtReadable);
|
|
console.log('ok 1');
|
|
});
|
|
})();
|
|
|
|
(function second() {
|
|
// second test, make sure that readable is re-emitted if there's
|
|
// already a length, while it IS reading.
|
|
|
|
var r = new Readable({
|
|
highWaterMark: 3
|
|
});
|
|
|
|
var _readCalled = false;
|
|
r._read = function(n) {
|
|
_readCalled = true;
|
|
};
|
|
|
|
// This triggers a 'readable' event, which is lost.
|
|
r.push(new Buffer('bl'));
|
|
|
|
var caughtReadable = false;
|
|
setTimeout(function() {
|
|
// assert we're testing what we think we are
|
|
assert(r._readableState.reading);
|
|
r.on('readable', function() {
|
|
caughtReadable = true;
|
|
});
|
|
});
|
|
|
|
process.on('exit', function() {
|
|
// we're testing what we think we are
|
|
assert(_readCalled);
|
|
|
|
assert(caughtReadable);
|
|
console.log('ok 2');
|
|
});
|
|
})();
|
|
|
|
(function third() {
|
|
// Third test, not reading when the stream has not passed
|
|
// the highWaterMark but *has* reached EOF.
|
|
var r = new Readable({
|
|
highWaterMark: 30
|
|
});
|
|
|
|
var _readCalled = false;
|
|
r._read = function(n) {
|
|
_readCalled = true;
|
|
};
|
|
|
|
// This triggers a 'readable' event, which is lost.
|
|
r.push(new Buffer('blerg'));
|
|
r.push(null);
|
|
|
|
var caughtReadable = false;
|
|
setTimeout(function() {
|
|
// assert we're testing what we think we are
|
|
assert(!r._readableState.reading);
|
|
r.on('readable', function() {
|
|
caughtReadable = true;
|
|
});
|
|
});
|
|
|
|
process.on('exit', function() {
|
|
// we're testing what we think we are
|
|
assert(!_readCalled);
|
|
|
|
assert(caughtReadable);
|
|
console.log('ok 3');
|
|
});
|
|
})();
|