summaryrefslogtreecommitdiff
path: root/test/parallel/test-stream2-pipe-error-handling.js
diff options
context:
space:
mode:
authorcjihrig <cjihrig@gmail.com>2016-07-12 19:47:32 -0400
committercjihrig <cjihrig@gmail.com>2016-07-14 22:07:14 -0400
commit4a408321d9c4a6964c9d89a0dd09067f36b4dbfc (patch)
tree5014fee0b2ef8772f4ebf60fd4bf27a72b0ef5b9 /test/parallel/test-stream2-pipe-error-handling.js
parent4220c24b17955f7f627bcedc89b6c2a0e655e618 (diff)
downloadnode-new-4a408321d9c4a6964c9d89a0dd09067f36b4dbfc.tar.gz
test: cleanup IIFE tests
A number of test files use IIFEs to separate distinct tests from each other in the same file. The project has been moving toward using block scopes and let/const in favor of IIFEs. This commit moves IIFE tests to block scopes. Some additional cleanup such as use of strictEqual() and common.mustCall() is also included. PR-URL: https://github.com/nodejs/node/pull/7694 Reviewed-By: Santiago Gimeno <santiago.gimeno@gmail.com>
Diffstat (limited to 'test/parallel/test-stream2-pipe-error-handling.js')
-rw-r--r--test/parallel/test-stream2-pipe-error-handling.js36
1 files changed, 18 insertions, 18 deletions
diff --git a/test/parallel/test-stream2-pipe-error-handling.js b/test/parallel/test-stream2-pipe-error-handling.js
index 65397566c2..bdf7a4a9a3 100644
--- a/test/parallel/test-stream2-pipe-error-handling.js
+++ b/test/parallel/test-stream2-pipe-error-handling.js
@@ -3,77 +3,77 @@ require('../common');
var assert = require('assert');
var stream = require('stream');
-(function testErrorListenerCatches() {
- var count = 1000;
+{
+ let count = 1000;
- var source = new stream.Readable();
+ const source = new stream.Readable();
source._read = function(n) {
n = Math.min(count, n);
count -= n;
source.push(Buffer.allocUnsafe(n));
};
- var unpipedDest;
+ let unpipedDest;
source.unpipe = function(dest) {
unpipedDest = dest;
stream.Readable.prototype.unpipe.call(this, dest);
};
- var dest = new stream.Writable();
+ const dest = new stream.Writable();
dest._write = function(chunk, encoding, cb) {
cb();
};
source.pipe(dest);
- var gotErr = null;
+ let gotErr = null;
dest.on('error', function(err) {
gotErr = err;
});
- var unpipedSource;
+ let unpipedSource;
dest.on('unpipe', function(src) {
unpipedSource = src;
});
- var err = new Error('This stream turned into bacon.');
+ const err = new Error('This stream turned into bacon.');
dest.emit('error', err);
assert.strictEqual(gotErr, err);
assert.strictEqual(unpipedSource, source);
assert.strictEqual(unpipedDest, dest);
-})();
+}
-(function testErrorWithoutListenerThrows() {
- var count = 1000;
+{
+ let count = 1000;
- var source = new stream.Readable();
+ const source = new stream.Readable();
source._read = function(n) {
n = Math.min(count, n);
count -= n;
source.push(Buffer.allocUnsafe(n));
};
- var unpipedDest;
+ let unpipedDest;
source.unpipe = function(dest) {
unpipedDest = dest;
stream.Readable.prototype.unpipe.call(this, dest);
};
- var dest = new stream.Writable();
+ const dest = new stream.Writable();
dest._write = function(chunk, encoding, cb) {
cb();
};
source.pipe(dest);
- var unpipedSource;
+ let unpipedSource;
dest.on('unpipe', function(src) {
unpipedSource = src;
});
- var err = new Error('This stream turned into bacon.');
+ const err = new Error('This stream turned into bacon.');
- var gotErr = null;
+ let gotErr = null;
try {
dest.emit('error', err);
} catch (e) {
@@ -82,4 +82,4 @@ var stream = require('stream');
assert.strictEqual(gotErr, err);
assert.strictEqual(unpipedSource, source);
assert.strictEqual(unpipedDest, dest);
-})();
+}