From 889d6198ec99e9d6cacbda67a1b773a2aaa23357 Mon Sep 17 00:00:00 2001
From: imhype <543717080@qq.com>
Date: Mon, 29 Apr 2019 11:08:53 +0800
Subject: [PATCH] test: add mustcall in test-net-bytes-read.js

* add mustcall() on createServerListener
* add mustcall() on listenPortListener
* add mustCall() on onConnectListener
* add mustCallAtLeast() on onDataListener
---
 test/parallel/test-net-bytes-read.js | 39 +++++++++++++++++-----------
 1 file changed, 24 insertions(+), 15 deletions(-)

diff --git a/test/parallel/test-net-bytes-read.js b/test/parallel/test-net-bytes-read.js
index fa6b2383b4f317..d569d78403e1d5 100644
--- a/test/parallel/test-net-bytes-read.js
+++ b/test/parallel/test-net-bytes-read.js
@@ -6,10 +6,12 @@ const net = require('net');
 
 const big = Buffer.alloc(1024 * 1024);
 
-const server = net.createServer((socket) => {
+const handler = common.mustCall((socket) => {
   socket.end(big);
   server.close();
-}).listen(0, () => {
+});
+
+const onListen = common.mustCall(() => {
   let prev = 0;
 
   function checkRaise(value) {
@@ -17,22 +19,29 @@ const server = net.createServer((socket) => {
     prev = value;
   }
 
-  const socket = net.connect(server.address().port, () => {
-    socket.on('data', (chunk) => {
-      checkRaise(socket.bytesRead);
-    });
+  const onData = common.mustCallAtLeast((chunk) => {
+    checkRaise(socket.bytesRead);
+  });
 
-    socket.on('end', common.mustCall(() => {
-      assert.strictEqual(socket.bytesRead, prev);
-      assert.strictEqual(big.length, prev);
-    }));
+  const onEnd = common.mustCall(() => {
+    assert.strictEqual(socket.bytesRead, prev);
+    assert.strictEqual(big.length, prev);
+  });
 
-    socket.on('close', common.mustCall(() => {
-      assert(!socket._handle);
-      assert.strictEqual(socket.bytesRead, prev);
-      assert.strictEqual(big.length, prev);
-    }));
+  const onClose = common.mustCall(() => {
+    assert(!socket._handle);
+    assert.strictEqual(socket.bytesRead, prev);
+    assert.strictEqual(big.length, prev);
+  });
 
+  const onConnect = common.mustCall(() => {
+    socket.on('data', onData);
+    socket.on('end', onEnd);
+    socket.on('close', onClose);
     socket.end();
   });
+
+  const socket = net.connect(server.address().port, onConnect);
 });
+
+const server = net.createServer(handler).listen(0, onListen);