summaryrefslogtreecommitdiff
path: root/test/parallel/test-stream-duplex.js
diff options
context:
space:
mode:
authorabouthiroppy <git@about-hiroppy.com>2017-01-23 22:27:00 +0900
committerJames M Snell <jasnell@gmail.com>2017-01-27 13:50:20 -0800
commit7ad012dbb137ab5d5912815fa53f7ecce5601e90 (patch)
treee9af8dc65fac232c053d5123bc10afe304e31003 /test/parallel/test-stream-duplex.js
parent3268863ebc40d1f0beee61b044c492b43fa57fa5 (diff)
downloadnode-new-7ad012dbb137ab5d5912815fa53f7ecce5601e90.tar.gz
test: increase coverage for stream's duplex
Make use of Arrow function. Add a small test and this file's coverage is 100%. https://github.com/nodejs/node/blob/a647d82f83ad5ddad5db7be2cc24c3d686121792/lib/_stream_duplex.js#L25 Coverage: https://coverage.nodejs.org/coverage-067be658f966dafe/root/_stream_duplex.js.html PR-URL: https://github.com/nodejs/node/pull/10963 Reviewed-By: Colin Ihrig <cjihrig@gmail.com> Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: Italo A. Casas <me@italoacasas.com> Reviewed-By: James M Snell <jasnell@gmail.com> Reviewed-By: Michael Dawson <michael_dawson@ca.ibm.com> Reviewed-By: Luigi Pinca <luigipinca@gmail.com> Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
Diffstat (limited to 'test/parallel/test-stream-duplex.js')
-rw-r--r--test/parallel/test-stream-duplex.js9
1 files changed, 5 insertions, 4 deletions
diff --git a/test/parallel/test-stream-duplex.js b/test/parallel/test-stream-duplex.js
index 85438c09fd..0b71b3d9a5 100644
--- a/test/parallel/test-stream-duplex.js
+++ b/test/parallel/test-stream-duplex.js
@@ -5,27 +5,28 @@ const Duplex = require('stream').Transform;
const stream = new Duplex({ objectMode: true });
+assert(Duplex() instanceof Duplex);
assert(stream._readableState.objectMode);
assert(stream._writableState.objectMode);
let written;
let read;
-stream._write = function(obj, _, cb) {
+stream._write = (obj, _, cb) => {
written = obj;
cb();
};
-stream._read = function() {};
+stream._read = () => {};
-stream.on('data', function(obj) {
+stream.on('data', (obj) => {
read = obj;
});
stream.push({ val: 1 });
stream.end({ val: 2 });
-process.on('exit', function() {
+process.on('exit', () => {
assert.strictEqual(read.val, 1);
assert.strictEqual(written.val, 2);
});