Browse Source

test: increase coverage for stream's duplex

Make use of Arrow function.
Add a small test and this file's coverage is 100%.
a647d82f83/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>
v6.x
abouthiroppy 8 years ago
committed by Myles Borins
parent
commit
174bef182a
No known key found for this signature in database GPG Key ID: 933B01F40B5CA946
  1. 9
      test/parallel/test-stream-duplex.js

9
test/parallel/test-stream-duplex.js

@ -5,27 +5,28 @@ const Duplex = require('stream').Transform;
const stream = new Duplex({ objectMode: true }); const stream = new Duplex({ objectMode: true });
assert(Duplex() instanceof Duplex);
assert(stream._readableState.objectMode); assert(stream._readableState.objectMode);
assert(stream._writableState.objectMode); assert(stream._writableState.objectMode);
let written; let written;
let read; let read;
stream._write = function(obj, _, cb) { stream._write = (obj, _, cb) => {
written = obj; written = obj;
cb(); cb();
}; };
stream._read = function() {}; stream._read = () => {};
stream.on('data', function(obj) { stream.on('data', (obj) => {
read = obj; read = obj;
}); });
stream.push({ val: 1 }); stream.push({ val: 1 });
stream.end({ val: 2 }); stream.end({ val: 2 });
process.on('exit', function() { process.on('exit', () => {
assert.strictEqual(read.val, 1); assert.strictEqual(read.val, 1);
assert.strictEqual(written.val, 2); assert.strictEqual(written.val, 2);
}); });

Loading…
Cancel
Save