@@ -82,8 +82,7 @@ describe('Integration | coreHandlers | handleAfterSendEvent', () => {
8282 expect ( Array . from ( replay . getContext ( ) . traceIds ) ) . toEqual ( [ 'tr2' ] ) ;
8383
8484 // Does not affect error session
85- vi . runAllTimers ( ) ;
86- await new Promise ( process . nextTick ) ;
85+ await vi . advanceTimersToNextTimerAsync ( ) ;
8786
8887 expect ( Array . from ( replay . getContext ( ) . errorIds ) ) . toEqual ( [ ] ) ;
8988 expect ( Array . from ( replay . getContext ( ) . traceIds ) ) . toEqual ( [ 'tr2' ] ) ;
@@ -208,8 +207,7 @@ describe('Integration | coreHandlers | handleAfterSendEvent', () => {
208207
209208 expect ( Array . from ( replay . getContext ( ) . errorIds ) ) . toEqual ( [ 'err1' ] ) ;
210209
211- vi . runAllTimers ( ) ;
212- await new Promise ( process . nextTick ) ;
210+ await vi . advanceTimersToNextTimerAsync ( ) ;
213211
214212 // Send once for the regular session sending
215213 expect ( mockSend ) . toHaveBeenCalledTimes ( 1 ) ;
@@ -244,8 +242,7 @@ describe('Integration | coreHandlers | handleAfterSendEvent', () => {
244242
245243 expect ( Array . from ( replay . getContext ( ) . errorIds ) ) . toEqual ( [ ] ) ;
246244
247- vi . runAllTimers ( ) ;
248- await new Promise ( process . nextTick ) ;
245+ await vi . advanceTimersToNextTimerAsync ( ) ;
249246
250247 expect ( mockSend ) . toHaveBeenCalledTimes ( 0 ) ;
251248 expect ( Array . from ( replay . getContext ( ) . errorIds ) ) . toEqual ( [ ] ) ;
@@ -277,8 +274,7 @@ describe('Integration | coreHandlers | handleAfterSendEvent', () => {
277274
278275 expect ( Array . from ( replay . getContext ( ) . errorIds ) ) . toEqual ( [ ] ) ;
279276
280- vi . runAllTimers ( ) ;
281- await new Promise ( process . nextTick ) ;
277+ await vi . advanceTimersToNextTimerAsync ( ) ;
282278
283279 // Remains in buffer mode & without flushing
284280 expect ( mockSend ) . toHaveBeenCalledTimes ( 0 ) ;
@@ -311,8 +307,7 @@ describe('Integration | coreHandlers | handleAfterSendEvent', () => {
311307
312308 expect ( Array . from ( replay . getContext ( ) . errorIds ) ) . toEqual ( [ 'err1' ] ) ;
313309
314- vi . runAllTimers ( ) ;
315- await new Promise ( process . nextTick ) ;
310+ await vi . advanceTimersToNextTimerAsync ( ) ;
316311
317312 // Remains in buffer mode & without flushing
318313 expect ( mockSend ) . toHaveBeenCalledTimes ( 0 ) ;
@@ -345,8 +340,7 @@ describe('Integration | coreHandlers | handleAfterSendEvent', () => {
345340
346341 expect ( Array . from ( replay . getContext ( ) . errorIds ) ) . toEqual ( [ 'err1' ] ) ;
347342
348- vi . runAllTimers ( ) ;
349- await new Promise ( process . nextTick ) ;
343+ await vi . advanceTimersToNextTimerAsync ( ) ;
350344
351345 // Remains in buffer mode & without flushing
352346 expect ( mockSend ) . toHaveBeenCalledTimes ( 0 ) ;
@@ -377,8 +371,7 @@ describe('Integration | coreHandlers | handleAfterSendEvent', () => {
377371
378372 replay [ '_isEnabled' ] = false ;
379373
380- vi . runAllTimers ( ) ;
381- await new Promise ( process . nextTick ) ;
374+ await vi . advanceTimersToNextTimerAsync ( ) ;
382375
383376 expect ( mockSend ) . toHaveBeenCalledTimes ( 0 ) ;
384377 } ) ;
@@ -408,8 +401,7 @@ describe('Integration | coreHandlers | handleAfterSendEvent', () => {
408401
409402 handler ( error1 , { statusCode : 200 } ) ;
410403
411- vi . runAllTimers ( ) ;
412- await new Promise ( process . nextTick ) ;
404+ await vi . advanceTimersToNextTimerAsync ( ) ;
413405
414406 expect ( beforeErrorSampling ) . toHaveBeenCalledTimes ( 1 ) ;
415407
@@ -420,8 +412,7 @@ describe('Integration | coreHandlers | handleAfterSendEvent', () => {
420412
421413 handler ( error2 , { statusCode : 200 } ) ;
422414
423- vi . runAllTimers ( ) ;
424- await new Promise ( process . nextTick ) ;
415+ await vi . advanceTimersToNextTimerAsync ( ) ;
425416
426417 expect ( beforeErrorSampling ) . toHaveBeenCalledTimes ( 2 ) ;
427418
0 commit comments