@@ -6,33 +6,42 @@ const net = require('net');
6
6
7
7
const big = Buffer . alloc ( 1024 * 1024 ) ;
8
8
9
- const server = net . createServer ( ( socket ) => {
9
+ const handler = common . mustCall ( ( socket ) => {
10
10
socket . end ( big ) ;
11
11
server . close ( ) ;
12
- } ) . listen ( 0 , ( ) => {
12
+ } ) ;
13
+
14
+ const onListen = common . mustCall ( ( ) => {
13
15
let prev = 0 ;
14
16
15
17
function checkRaise ( value ) {
16
18
assert ( value > prev ) ;
17
19
prev = value ;
18
20
}
19
21
20
- const socket = net . connect ( server . address ( ) . port , ( ) => {
21
- socket . on ( 'data' , ( chunk ) => {
22
- checkRaise ( socket . bytesRead ) ;
23
- } ) ;
22
+ const onData = common . mustCallAtLeast ( ( chunk ) => {
23
+ checkRaise ( socket . bytesRead ) ;
24
+ } ) ;
24
25
25
- socket . on ( 'end' , common . mustCall ( ( ) => {
26
- assert . strictEqual ( socket . bytesRead , prev ) ;
27
- assert . strictEqual ( big . length , prev ) ;
28
- } ) ) ;
26
+ const onEnd = common . mustCall ( ( ) => {
27
+ assert . strictEqual ( socket . bytesRead , prev ) ;
28
+ assert . strictEqual ( big . length , prev ) ;
29
+ } ) ;
29
30
30
- socket . on ( 'close' , common . mustCall ( ( ) => {
31
- assert ( ! socket . _handle ) ;
32
- assert . strictEqual ( socket . bytesRead , prev ) ;
33
- assert . strictEqual ( big . length , prev ) ;
34
- } ) ) ;
31
+ const onClose = common . mustCall ( ( ) => {
32
+ assert ( ! socket . _handle ) ;
33
+ assert . strictEqual ( socket . bytesRead , prev ) ;
34
+ assert . strictEqual ( big . length , prev ) ;
35
+ } ) ;
35
36
37
+ const onConnect = common . mustCall ( ( ) => {
38
+ socket . on ( 'data' , onData ) ;
39
+ socket . on ( 'end' , onEnd ) ;
40
+ socket . on ( 'close' , onClose ) ;
36
41
socket . end ( ) ;
37
42
} ) ;
43
+
44
+ const socket = net . connect ( server . address ( ) . port , onConnect ) ;
38
45
} ) ;
46
+
47
+ const server = net . createServer ( handler ) . listen ( 0 , onListen ) ;
0 commit comments