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

test: replace callback with arrow functions

Browse Source 
PR-URL: https://github.com/nodejs/node/pull/24541
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Gireesh Punathil <gpunathi@in.ibm.com>
This commit is contained in:
sreepurnajasti 2018-11-20 12:49:01 +05:30 committed by Anna Henningsen
parent d45e303ac6
commit c90b514275
No known key found for this signature in database
GPG Key ID: 9C63F3A6CD2AD8F9
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
test/pummel/test-net-throttle.js
View File

@ -34,7 +34,7 @@ const body = 'C'.repeat(N);
console.log(`start server on port ${common.PORT}`); console.log(`start server on port ${common.PORT}`);
const server = net.createServer(function(connection) { const server = net.createServer((connection) => {
connection.write(body.slice(0, part_N)); connection.write(body.slice(0, part_N));
connection.write(body.slice(part_N, 2 * part_N)); connection.write(body.slice(part_N, 2 * part_N));
assert.strictEqual(connection.write(body.slice(2 * part_N, N)), false); assert.strictEqual(connection.write(body.slice(2 * part_N, N)), false);
@ -44,11 +44,11 @@ const server = net.createServer(function(connection) {
connection.end(); connection.end();
}); });
server.listen(common.PORT, function() { server.listen(common.PORT, () => {
let paused = false; let paused = false;
const client = net.createConnection(common.PORT); const client = net.createConnection(common.PORT);
client.setEncoding('ascii'); client.setEncoding('ascii');
client.on('data', function(d) { client.on('data', (d) => {
chars_recved += d.length; chars_recved += d.length;
console.log(`got ${chars_recved}`); console.log(`got ${chars_recved}`);
if (!paused) { if (!paused) {
@ -57,7 +57,7 @@ server.listen(common.PORT, function() {
paused = true; paused = true;
console.log('pause'); console.log('pause');
const x = chars_recved; const x = chars_recved;
setTimeout(function() { setTimeout(() => {
assert.strictEqual(chars_recved, x); assert.strictEqual(chars_recved, x);
client.resume(); client.resume();
console.log('resume'); console.log('resume');
@ -66,14 +66,14 @@ server.listen(common.PORT, function() {
} }
}); });
client.on('end', function() { client.on('end', () => {
server.close(); server.close();
client.end(); client.end();
}); });
}); });
process.on('exit', function() { process.on('exit', () => {
assert.strictEqual(chars_recved, N); assert.strictEqual(chars_recved, N);
assert.strictEqual(npauses > 2, true); assert.strictEqual(npauses > 2, true);
}); });