diff options
author | abouthiroppy <git@about-hiroppy.com> | 2017-01-23 22:27:00 +0900 |
---|---|---|
committer | James M Snell <jasnell@gmail.com> | 2017-01-27 13:50:20 -0800 |
commit | 7ad012dbb137ab5d5912815fa53f7ecce5601e90 (patch) | |
tree | e9af8dc65fac232c053d5123bc10afe304e31003 /test/parallel/test-stream-duplex.js | |
parent | 3268863ebc40d1f0beee61b044c492b43fa57fa5 (diff) | |
download | node-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.js | 9 |
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); }); |