@@ -18,7 +18,6 @@ import {
18
18
ISubprocessRunnerMessage ,
19
19
ISubprocessSyncedData ,
20
20
ISuite ,
21
- ITaskOutput ,
22
21
} from '../interfaces' ;
23
22
24
23
const debugLog = debug ( 'mocha-parallel-tests' ) ;
@@ -84,9 +83,9 @@ export default class MochaWrapper extends Mocha {
84
83
runner . fullStackTrace = fullStackTrace ;
85
84
runner . asyncOnly = asyncOnly ;
86
85
87
- const tasks : Array < ( ) => Promise < ITaskOutput < ISubprocessResult > > > = [ ] ;
86
+ const tasks : Array < ( ) => Promise < ISubprocessResult > > = [ ] ;
88
87
for ( const file of this . files ) {
89
- const task = ( ) => this . spawnTestProcess ( file , task ) ;
88
+ const task = ( ) => this . spawnTestProcess ( file ) ;
90
89
tasks . push ( task ) ;
91
90
}
92
91
@@ -135,11 +134,7 @@ export default class MochaWrapper extends Mocha {
135
134
136
135
Promise . all ( tasks . map ( async ( task ) => {
137
136
const res = await task ( ) ;
138
- const output = res . output ;
139
- assert ( output ) ;
140
- if ( output ) {
141
- onTaskFinished ( output ) ;
142
- }
137
+ onTaskFinished ( res ) ;
143
138
} ) ) . then ( ( ) => {
144
139
debugLog ( 'All tests finished processing' ) ;
145
140
@@ -177,8 +172,8 @@ export default class MochaWrapper extends Mocha {
177
172
return retriesTests as IRetriedTest [ ] ;
178
173
}
179
174
180
- private async spawnTestProcess ( file : string , task : any ) : Promise < ITaskOutput < ISubprocessResult > > {
181
- const output : ISubprocessResult = await new Promise < ISubprocessResult > ( async ( resolve , reject ) => {
175
+ private async spawnTestProcess ( file : string ) : Promise < ISubprocessResult > {
176
+ return new Promise < ISubprocessResult > ( async ( resolve , reject ) => {
182
177
const resolvedFilePath = pathResolve ( file ) ;
183
178
184
179
const testOptions : { [ key : string ] : any } = { test : resolvedFilePath } ;
@@ -284,9 +279,5 @@ export default class MochaWrapper extends Mocha {
284
279
return null ;
285
280
}
286
281
} ) ;
287
- return {
288
- output,
289
- task,
290
- } ;
291
282
}
292
283
}
0 commit comments