File tree 1 file changed +16
-16
lines changed
1 file changed +16
-16
lines changed Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ if (cluster.isMaster) {
30
30
31
31
const worker = cluster . fork ( ) ;
32
32
33
- worker . on ( 'exit' , function ( code ) {
33
+ worker . on ( 'exit' , ( code ) => {
34
34
assert . strictEqual ( code , OK ) ;
35
35
process . exit ( 0 ) ;
36
36
} ) ;
@@ -49,31 +49,31 @@ assert(cluster.isWorker);
49
49
let sawProcess ;
50
50
let sawWorker ;
51
51
52
- process . on ( 'message' , function ( m ) {
53
- assert ( ! sawProcess ) ;
54
- sawProcess = true ;
55
- check ( m ) ;
56
- } ) ;
57
-
58
- cluster . worker . on ( 'message' , function ( m ) {
59
- assert ( ! sawWorker ) ;
60
- sawWorker = true ;
61
- check ( m ) ;
62
- } ) ;
63
-
64
52
const messages = [ ] ;
65
53
66
- function check ( m ) {
54
+ const check = ( m ) => {
67
55
messages . push ( m ) ;
68
56
69
57
if ( messages . length < 2 ) return ;
70
58
71
59
assert . deepStrictEqual ( messages [ 0 ] , messages [ 1 ] ) ;
72
60
73
- cluster . worker . once ( 'error' , function ( e ) {
61
+ cluster . worker . once ( 'error' , ( e ) => {
74
62
assert . strictEqual ( e , 'HI' ) ;
75
63
process . exit ( OK ) ;
76
64
} ) ;
77
65
78
66
process . emit ( 'error' , 'HI' ) ;
79
- }
67
+ } ;
68
+
69
+ process . on ( 'message' , ( m ) => {
70
+ assert ( ! sawProcess ) ;
71
+ sawProcess = true ;
72
+ check ( m ) ;
73
+ } ) ;
74
+
75
+ cluster . worker . on ( 'message' , ( m ) => {
76
+ assert ( ! sawWorker ) ;
77
+ sawWorker = true ;
78
+ check ( m ) ;
79
+ } ) ;
You can’t perform that action at this time.
0 commit comments