@@ -182,10 +182,14 @@ test('should fire onerror before onclose on stdout error', async () => {
182182
183183test ( 'should fire onclose when stdin emits close' , async ( ) => {
184184 const server = new StdioServerTransport ( input , output ) ;
185- server . onerror = error => { throw error ; } ;
185+ server . onerror = error => {
186+ throw error ;
187+ } ;
186188
187189 let closeCount = 0 ;
188- server . onclose = ( ) => { closeCount ++ ; } ;
190+ server . onclose = ( ) => {
191+ closeCount ++ ;
192+ } ;
189193
190194 await server . start ( ) ;
191195 input . emit ( 'close' ) ;
@@ -202,12 +206,18 @@ test('should fire onclose when stdin emits end', async () => {
202206 read : ( ) => { }
203207 } ) ;
204208 const server = new StdioServerTransport ( endOnlyInput , output ) ;
205- server . onerror = error => { throw error ; } ;
209+ server . onerror = error => {
210+ throw error ;
211+ } ;
206212
207213 let closeCount = 0 ;
208214 let inputCloseCount = 0 ;
209- server . onclose = ( ) => { closeCount ++ ; } ;
210- endOnlyInput . on ( 'close' , ( ) => { inputCloseCount ++ ; } ) ;
215+ server . onclose = ( ) => {
216+ closeCount ++ ;
217+ } ;
218+ endOnlyInput . on ( 'close' , ( ) => {
219+ inputCloseCount ++ ;
220+ } ) ;
211221
212222 await server . start ( ) ;
213223 endOnlyInput . push ( null ) ; // signals end-of-stream without emitting close
@@ -224,7 +234,9 @@ test('should not fire onclose twice when close() called after stdin close', asyn
224234 server . onerror = ( ) => { } ;
225235
226236 let closeCount = 0 ;
227- server . onclose = ( ) => { closeCount ++ ; } ;
237+ server . onclose = ( ) => {
238+ closeCount ++ ;
239+ } ;
228240
229241 await server . start ( ) ;
230242 input . emit ( 'close' ) ;
0 commit comments