@@ -212,63 +212,31 @@ function initializeListeners() {
212212
213213 collectStats ( ) ;
214214 // suite
215- event . dispatcher . on ( event . suite . before , ( suite ) =>
216- sendToParentThread ( { event : event . suite . before , workerIndex, data : simplifyTest ( suite ) } ) ,
217- ) ;
218- event . dispatcher . on ( event . suite . after , ( suite ) =>
219- sendToParentThread ( { event : event . suite . after , workerIndex, data : simplifyTest ( suite ) } ) ,
220- ) ;
215+ event . dispatcher . on ( event . suite . before , ( suite ) => sendToParentThread ( { event : event . suite . before , workerIndex, data : simplifyTest ( suite ) } ) ) ;
216+ event . dispatcher . on ( event . suite . after , ( suite ) => sendToParentThread ( { event : event . suite . after , workerIndex, data : simplifyTest ( suite ) } ) ) ;
221217
222218 // calculate duration
223219 event . dispatcher . on ( event . test . started , ( test ) => ( test . start = new Date ( ) ) ) ;
224220
225221 // tests
226- event . dispatcher . on ( event . test . before , ( test ) =>
227- sendToParentThread ( { event : event . test . before , workerIndex, data : simplifyTest ( test ) } ) ,
228- ) ;
229- event . dispatcher . on ( event . test . after , ( test ) =>
230- sendToParentThread ( { event : event . test . after , workerIndex, data : simplifyTest ( test ) } ) ,
231- ) ;
222+ event . dispatcher . on ( event . test . before , ( test ) => sendToParentThread ( { event : event . test . before , workerIndex, data : simplifyTest ( test ) } ) ) ;
223+ event . dispatcher . on ( event . test . after , ( test ) => sendToParentThread ( { event : event . test . after , workerIndex, data : simplifyTest ( test ) } ) ) ;
232224 // we should force-send correct errors to prevent race condition
233- event . dispatcher . on ( event . test . finished , ( test , err ) =>
234- sendToParentThread ( { event : event . test . finished , workerIndex, data : simplifyTest ( test , err ) } ) ,
235- ) ;
236- event . dispatcher . on ( event . test . failed , ( test , err ) =>
237- sendToParentThread ( { event : event . test . failed , workerIndex, data : simplifyTest ( test , err ) } ) ,
238- ) ;
239- event . dispatcher . on ( event . test . passed , ( test , err ) =>
240- sendToParentThread ( { event : event . test . passed , workerIndex, data : simplifyTest ( test , err ) } ) ,
241- ) ;
242- event . dispatcher . on ( event . test . started , ( test ) =>
243- sendToParentThread ( { event : event . test . started , workerIndex, data : simplifyTest ( test ) } ) ,
244- ) ;
245- event . dispatcher . on ( event . test . skipped , ( test ) =>
246- sendToParentThread ( { event : event . test . skipped , workerIndex, data : simplifyTest ( test ) } ) ,
247- ) ;
225+ event . dispatcher . on ( event . test . finished , ( test , err ) => sendToParentThread ( { event : event . test . finished , workerIndex, data : simplifyTest ( test , err ) } ) ) ;
226+ event . dispatcher . on ( event . test . failed , ( test , err ) => sendToParentThread ( { event : event . test . failed , workerIndex, data : simplifyTest ( test , err ) } ) ) ;
227+ event . dispatcher . on ( event . test . passed , ( test , err ) => sendToParentThread ( { event : event . test . passed , workerIndex, data : simplifyTest ( test , err ) } ) ) ;
228+ event . dispatcher . on ( event . test . started , ( test ) => sendToParentThread ( { event : event . test . started , workerIndex, data : simplifyTest ( test ) } ) ) ;
229+ event . dispatcher . on ( event . test . skipped , ( test ) => sendToParentThread ( { event : event . test . skipped , workerIndex, data : simplifyTest ( test ) } ) ) ;
248230
249231 // steps
250- event . dispatcher . on ( event . step . finished , ( step ) =>
251- sendToParentThread ( { event : event . step . finished , workerIndex, data : simplifyStep ( step ) } ) ,
252- ) ;
253- event . dispatcher . on ( event . step . started , ( step ) =>
254- sendToParentThread ( { event : event . step . started , workerIndex, data : simplifyStep ( step ) } ) ,
255- ) ;
256- event . dispatcher . on ( event . step . passed , ( step ) =>
257- sendToParentThread ( { event : event . step . passed , workerIndex, data : simplifyStep ( step ) } ) ,
258- ) ;
259- event . dispatcher . on ( event . step . failed , ( step ) =>
260- sendToParentThread ( { event : event . step . failed , workerIndex, data : simplifyStep ( step ) } ) ,
261- ) ;
262-
263- event . dispatcher . on ( event . hook . failed , ( test , err ) =>
264- sendToParentThread ( { event : event . hook . failed , workerIndex, data : simplifyTest ( test , err ) } ) ,
265- ) ;
266- event . dispatcher . on ( event . hook . passed , ( test , err ) =>
267- sendToParentThread ( { event : event . hook . passed , workerIndex, data : simplifyTest ( test , err ) } ) ,
268- ) ;
269- event . dispatcher . on ( event . all . failures , ( data ) =>
270- sendToParentThread ( { event : event . all . failures , workerIndex, data } ) ,
271- ) ;
232+ event . dispatcher . on ( event . step . finished , ( step ) => sendToParentThread ( { event : event . step . finished , workerIndex, data : simplifyStep ( step ) } ) ) ;
233+ event . dispatcher . on ( event . step . started , ( step ) => sendToParentThread ( { event : event . step . started , workerIndex, data : simplifyStep ( step ) } ) ) ;
234+ event . dispatcher . on ( event . step . passed , ( step ) => sendToParentThread ( { event : event . step . passed , workerIndex, data : simplifyStep ( step ) } ) ) ;
235+ event . dispatcher . on ( event . step . failed , ( step ) => sendToParentThread ( { event : event . step . failed , workerIndex, data : simplifyStep ( step ) } ) ) ;
236+
237+ event . dispatcher . on ( event . hook . failed , ( test , err ) => sendToParentThread ( { event : event . hook . failed , workerIndex, data : simplifyTest ( test , err ) } ) ) ;
238+ event . dispatcher . on ( event . hook . passed , ( test , err ) => sendToParentThread ( { event : event . hook . passed , workerIndex, data : simplifyTest ( test , err ) } ) ) ;
239+ event . dispatcher . on ( event . all . failures , ( data ) => sendToParentThread ( { event : event . all . failures , workerIndex, data } ) ) ;
272240
273241 // all
274242 event . dispatcher . once ( event . all . result , ( ) => parentPort . close ( ) ) ;
0 commit comments