Browse Source

test: refactor test-stream2-unpipe-drain

- Change var to const
- Remove dependency crypto

PR-URL: https://github.com/nodejs/node/pull/10033
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>
v6
Chris Story 8 years ago
committed by Italo A. Casas
parent
commit
627fa93095
  1. 26
      test/parallel/test-stream2-unpipe-drain.js

26
test/parallel/test-stream2-unpipe-drain.js

@ -1,15 +1,9 @@
'use strict'; 'use strict';
var common = require('../common'); require('../common');
var assert = require('assert'); const assert = require('assert');
var stream = require('stream');
if (!common.hasCrypto) { const stream = require('stream');
common.skip('missing crypto'); const util = require('util');
return;
}
var crypto = require('crypto');
var util = require('util');
function TestWriter() { function TestWriter() {
stream.Writable.call(this); stream.Writable.call(this);
@ -21,7 +15,7 @@ TestWriter.prototype._write = function(buffer, encoding, callback) {
// super slow write stream (callback never called) // super slow write stream (callback never called)
}; };
var dest = new TestWriter(); const dest = new TestWriter();
function TestReader(id) { function TestReader(id) {
stream.Readable.call(this); stream.Readable.call(this);
@ -31,11 +25,11 @@ util.inherits(TestReader, stream.Readable);
TestReader.prototype._read = function(size) { TestReader.prototype._read = function(size) {
this.reads += 1; this.reads += 1;
this.push(crypto.randomBytes(size)); this.push(Buffer.alloc(size));
}; };
var src1 = new TestReader(); const src1 = new TestReader();
var src2 = new TestReader(); const src2 = new TestReader();
src1.pipe(dest); src1.pipe(dest);
@ -55,6 +49,6 @@ src1.once('readable', function() {
process.on('exit', function() { process.on('exit', function() {
assert.equal(src1.reads, 2); assert.strictEqual(src1.reads, 2);
assert.equal(src2.reads, 2); assert.strictEqual(src2.reads, 2);
}); });

Loading…
Cancel
Save