File tree Expand file tree Collapse file tree 1 file changed +16
-16
lines changed Expand file tree Collapse file tree 1 file changed +16
-16
lines changed Original file line number Diff line number Diff line change @@ -30,7 +30,7 @@ if (cluster.isMaster) {
3030
3131 const worker = cluster . fork ( ) ;
3232
33- worker . on ( 'exit' , function ( code ) {
33+ worker . on ( 'exit' , ( code ) => {
3434 assert . strictEqual ( code , OK ) ;
3535 process . exit ( 0 ) ;
3636 } ) ;
@@ -49,31 +49,31 @@ assert(cluster.isWorker);
4949let sawProcess ;
5050let sawWorker ;
5151
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-
6452const messages = [ ] ;
6553
66- function check ( m ) {
54+ const check = ( m ) => {
6755 messages . push ( m ) ;
6856
6957 if ( messages . length < 2 ) return ;
7058
7159 assert . deepStrictEqual ( messages [ 0 ] , messages [ 1 ] ) ;
7260
73- cluster . worker . once ( 'error' , function ( e ) {
61+ cluster . worker . once ( 'error' , ( e ) => {
7462 assert . strictEqual ( e , 'HI' ) ;
7563 process . exit ( OK ) ;
7664 } ) ;
7765
7866 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