@@ -28,44 +28,44 @@ const N = 200;
28
28
let recv = '' ;
29
29
let chars_recved = 0 ;
30
30
31
- const server = net . createServer ( function ( connection ) {
31
+ const server = net . createServer ( ( connection ) => {
32
32
function write ( j ) {
33
33
if ( j >= N ) {
34
34
connection . end ( ) ;
35
35
return ;
36
36
}
37
- setTimeout ( function ( ) {
37
+ setTimeout ( ( ) => {
38
38
connection . write ( 'C' ) ;
39
39
write ( j + 1 ) ;
40
40
} , 10 ) ;
41
41
}
42
42
write ( 0 ) ;
43
43
} ) ;
44
44
45
- server . on ( 'listening' , function ( ) {
45
+ server . on ( 'listening' , ( ) => {
46
46
const client = net . createConnection ( common . PORT ) ;
47
47
client . setEncoding ( 'ascii' ) ;
48
48
client . on ( 'data' , function ( d ) {
49
49
console . log ( d ) ;
50
50
recv += d ;
51
51
} ) ;
52
52
53
- setTimeout ( function ( ) {
53
+ setTimeout ( ( ) => {
54
54
chars_recved = recv . length ;
55
55
console . log ( `pause at: ${ chars_recved } ` ) ;
56
56
assert . strictEqual ( chars_recved > 1 , true ) ;
57
57
client . pause ( ) ;
58
- setTimeout ( function ( ) {
58
+ setTimeout ( ( ) => {
59
59
console . log ( `resume at: ${ chars_recved } ` ) ;
60
60
assert . strictEqual ( chars_recved , recv . length ) ;
61
61
client . resume ( ) ;
62
62
63
- setTimeout ( function ( ) {
63
+ setTimeout ( ( ) => {
64
64
chars_recved = recv . length ;
65
65
console . log ( `pause at: ${ chars_recved } ` ) ;
66
66
client . pause ( ) ;
67
67
68
- setTimeout ( function ( ) {
68
+ setTimeout ( ( ) => {
69
69
console . log ( `resume at: ${ chars_recved } ` ) ;
70
70
assert . strictEqual ( chars_recved , recv . length ) ;
71
71
client . resume ( ) ;
@@ -78,14 +78,14 @@ server.on('listening', function() {
78
78
79
79
} , 500 ) ;
80
80
81
- client . on ( 'end' , function ( ) {
81
+ client . on ( 'end' , ( ) => {
82
82
server . close ( ) ;
83
83
client . end ( ) ;
84
84
} ) ;
85
85
} ) ;
86
86
server . listen ( common . PORT ) ;
87
87
88
- process . on ( 'exit' , function ( ) {
88
+ process . on ( 'exit' , ( ) => {
89
89
assert . strictEqual ( recv . length , N ) ;
90
90
console . error ( 'Exit' ) ;
91
91
} ) ;
0 commit comments