@@ -46,17 +46,17 @@ function test1() {
46
46
r . _read = function ( n ) {
47
47
switch ( reads -- ) {
48
48
case 5 :
49
- return setImmediate ( function ( ) {
49
+ return setImmediate ( ( ) => {
50
50
return r . push ( buf ) ;
51
51
} ) ;
52
52
case 4 :
53
- setImmediate ( function ( ) {
53
+ setImmediate ( ( ) => {
54
54
return r . push ( Buffer . alloc ( 0 ) ) ;
55
55
} ) ;
56
56
return setImmediate ( r . read . bind ( r , 0 ) ) ;
57
57
case 3 :
58
58
setImmediate ( r . read . bind ( r , 0 ) ) ;
59
- return process . nextTick ( function ( ) {
59
+ return process . nextTick ( ( ) => {
60
60
return r . push ( Buffer . alloc ( 0 ) ) ;
61
61
} ) ;
62
62
case 2 :
@@ -78,12 +78,12 @@ function test1() {
78
78
results . push ( String ( chunk ) ) ;
79
79
}
80
80
r . on ( 'readable' , flow ) ;
81
- r . on ( 'end' , function ( ) {
81
+ r . on ( 'end' , ( ) => {
82
82
results . push ( 'EOF' ) ;
83
83
} ) ;
84
84
flow ( ) ;
85
85
86
- process . on ( 'exit' , function ( ) {
86
+ process . on ( 'exit' , ( ) => {
87
87
assert . deepStrictEqual ( results , [ 'xxxxx' , 'xxxxx' , 'EOF' ] ) ;
88
88
console . log ( 'ok' ) ;
89
89
} ) ;
@@ -106,12 +106,12 @@ function test2() {
106
106
results . push ( String ( chunk ) ) ;
107
107
}
108
108
r . on ( 'readable' , flow ) ;
109
- r . on ( 'end' , function ( ) {
109
+ r . on ( 'end' , ( ) => {
110
110
results . push ( 'EOF' ) ;
111
111
} ) ;
112
112
flow ( ) ;
113
113
114
- process . on ( 'exit' , function ( ) {
114
+ process . on ( 'exit' , ( ) => {
115
115
assert . deepStrictEqual ( results , [ 'eHh4' , 'eHg=' , 'EOF' ] ) ;
116
116
console . log ( 'ok' ) ;
117
117
} ) ;
0 commit comments