1berry/nodejs
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test: use arrow functions in callbacks

Browse Source 
PR-URL: https://github.com/nodejs/node/pull/24441
Reviewed-By: Michaël Zasso <targos@protonmail.com>
Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Gireesh Punathil <gpunathi@in.ibm.com>
This commit is contained in:
apoorvanand 2018-11-17 18:28:07 +05:30 committed by Rich Trott
parent 7d18e922ab
commit b5c5d206af
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
test/parallel/test-stream-pipe-await-drain.js
View File

@ -22,14 +22,14 @@ writer1._write = common.mustCall(function(chunk, encoding, cb) {
cb(); cb();
}, 1); }, 1);
writer1.once('chunk-received', function() { writer1.once('chunk-received', () => {
assert.strictEqual( assert.strictEqual(
reader._readableState.awaitDrain, reader._readableState.awaitDrain,
0, 0,
'awaitDrain initial value should be 0, actual is ' + 'awaitDrain initial value should be 0, actual is ' +
reader._readableState.awaitDrain reader._readableState.awaitDrain
); );
setImmediate(function() { setImmediate(() => {
// This one should *not* get through to writer1 because writer2 is not // This one should *not* get through to writer1 because writer2 is not
// "done" processing. // "done" processing.
reader.push(buffer); reader.push(buffer);
@ -37,7 +37,7 @@ writer1.once('chunk-received', function() {
}); });
// A "slow" consumer: // A "slow" consumer:
writer2._write = common.mustCall(function(chunk, encoding, cb) { writer2._write = common.mustCall((chunk, encoding, cb) => {
assert.strictEqual( assert.strictEqual(
reader._readableState.awaitDrain, reader._readableState.awaitDrain,
1, 1,
@ -49,7 +49,7 @@ writer2._write = common.mustCall(function(chunk, encoding, cb) {
// will return false. // will return false.
}, 1); }, 1);
writer3._write = common.mustCall(function(chunk, encoding, cb) { writer3._write = common.mustCall((chunk, encoding, cb) => {
assert.strictEqual( assert.strictEqual(
reader._readableState.awaitDrain, reader._readableState.awaitDrain,
2, 2,