@@ -55,6 +55,7 @@ class Api extends EventEmitter {
55
55
this . options = Object . assign ( { match : [ ] } , options ) ;
56
56
this . options . require = resolveModules ( this . options . require ) ;
57
57
}
58
+
58
59
_runFile ( file , runStatus , execArgv ) {
59
60
const hash = this . precompiler . precompileFile ( file ) ;
60
61
const precompiled = Object . assign ( { } , this . _precompiledHelpers ) ;
@@ -71,17 +72,20 @@ class Api extends EventEmitter {
71
72
72
73
return emitter ;
73
74
}
75
+
74
76
run ( files , options ) {
75
77
return new AvaFiles ( { cwd : this . options . resolveTestsFrom , files} )
76
78
. findTestFiles ( )
77
79
. then ( files => this . _run ( files , options ) ) ;
78
80
}
81
+
79
82
_onTimeout ( runStatus ) {
80
83
const timeout = ms ( this . options . timeout ) ;
81
84
const err = new AvaError ( `Exited because no new tests completed within the last ${ timeout } ms of inactivity` ) ;
82
85
this . _handleError ( runStatus , err ) ;
83
86
runStatus . emit ( 'timeout' ) ;
84
87
}
88
+
85
89
_setupTimeout ( runStatus ) {
86
90
const timeout = ms ( this . options . timeout ) ;
87
91
@@ -92,9 +96,11 @@ class Api extends EventEmitter {
92
96
runStatus . _restartTimer ( ) ;
93
97
runStatus . on ( 'test' , runStatus . _restartTimer ) ;
94
98
}
99
+
95
100
_cancelTimeout ( runStatus ) {
96
101
runStatus . _restartTimer . cancel ( ) ;
97
102
}
103
+
98
104
_setupPrecompiler ( files ) {
99
105
const isCacheEnabled = this . options . cacheEnabled !== false ;
100
106
let cacheDir = uniqueTempDir ( ) ;
@@ -121,6 +127,7 @@ class Api extends EventEmitter {
121
127
} ) ;
122
128
} ) ;
123
129
}
130
+
124
131
_precompileHelpers ( ) {
125
132
this . _precompiledHelpers = { } ;
126
133
@@ -136,6 +143,7 @@ class Api extends EventEmitter {
136
143
this . _precompiledHelpers [ file ] = hash ;
137
144
} ) ;
138
145
}
146
+
139
147
_run ( files , options ) {
140
148
options = options || { } ;
141
149
@@ -175,6 +183,7 @@ class Api extends EventEmitter {
175
183
return this . _runWithPool ( files , runStatus , concurrency ) ;
176
184
} ) ;
177
185
}
186
+
178
187
_computeForkExecArgs ( files ) {
179
188
const execArgv = this . options . testOnlyExecArgv || process . execArgv ;
180
189
let debugArgIndex = - 1 ;
@@ -220,12 +229,14 @@ class Api extends EventEmitter {
220
229
return forkExecArgv ;
221
230
} ) ;
222
231
}
232
+
223
233
_handleError ( runStatus , err ) {
224
234
runStatus . handleExceptions ( {
225
235
exception : err ,
226
236
file : err . file ? path . relative ( process . cwd ( ) , err . file ) : undefined
227
237
} ) ;
228
238
}
239
+
229
240
_runWithPool ( files , runStatus , concurrency ) {
230
241
const tests = [ ] ;
231
242
let execArgvList ;
0 commit comments