@@ -97,8 +97,8 @@ describe('ChatMLFetcherImpl retry logic', () => {
9797 mockFetcherService . queueResponse ( createSuccessResponse ( 'Hello!' ) ) ; // retry
9898
9999 const resultPromise = fetcher . fetchMany ( createBaseOpts ( ) , cancellationTokenSource . token ) ;
100- // Advance timers to skip the 1000ms delay before connectivity check
101- await vi . advanceTimersByTimeAsync ( 1000 ) ;
100+ // Run all pending timers to complete the connectivity check delays
101+ await vi . runAllTimersAsync ( ) ;
102102 const result = await resultPromise ;
103103
104104 expect ( result . type ) . toBe ( ChatFetchResponseType . Success ) ;
@@ -112,7 +112,7 @@ describe('ChatMLFetcherImpl retry logic', () => {
112112 mockFetcherService . queueResponse ( createSuccessResponse ( 'Success!' ) ) ; // retry
113113
114114 const resultPromise = fetcher . fetchMany ( createBaseOpts ( ) , cancellationTokenSource . token ) ;
115- await vi . advanceTimersByTimeAsync ( 1000 ) ;
115+ await vi . runAllTimersAsync ( ) ;
116116 const result = await resultPromise ;
117117
118118 expect ( result . type ) . toBe ( ChatFetchResponseType . Success ) ;
@@ -163,7 +163,7 @@ describe('ChatMLFetcherImpl retry logic', () => {
163163 mockFetcherService . queueResponse ( createSuccessResponse ( 'Success!' ) ) ; // retry
164164
165165 const resultPromise = fetcher . fetchMany ( createBaseOpts ( ) , cancellationTokenSource . token ) ;
166- await vi . advanceTimersByTimeAsync ( 1000 ) ;
166+ await vi . runAllTimersAsync ( ) ;
167167 const result = await resultPromise ;
168168
169169 expect ( result . type ) . toBe ( ChatFetchResponseType . Success ) ;
@@ -191,7 +191,7 @@ describe('ChatMLFetcherImpl retry logic', () => {
191191 mockFetcherService . queueResponse ( createSuccessResponse ( 'Success!' ) ) ; // retry
192192
193193 const resultPromise = fetcher . fetchMany ( createBaseOpts ( ) , cancellationTokenSource . token ) ;
194- await vi . advanceTimersByTimeAsync ( 1000 ) ;
194+ await vi . runAllTimersAsync ( ) ;
195195 const result = await resultPromise ;
196196
197197 expect ( result . type ) . toBe ( ChatFetchResponseType . Success ) ;
@@ -206,7 +206,7 @@ describe('ChatMLFetcherImpl retry logic', () => {
206206
207207 // Should still retry on 500 even with invalid entry in config
208208 const resultPromise = fetcher . fetchMany ( createBaseOpts ( ) , cancellationTokenSource . token ) ;
209- await vi . advanceTimersByTimeAsync ( 1000 ) ;
209+ await vi . runAllTimersAsync ( ) ;
210210 const result = await resultPromise ;
211211
212212 expect ( result . type ) . toBe ( ChatFetchResponseType . Success ) ;
@@ -249,8 +249,8 @@ describe('ChatMLFetcherImpl retry logic', () => {
249249 mockFetcherService . queueError ( createNetworkError ( 'ENOTFOUND' ) ) ; // 3rd connectivity check
250250
251251 const resultPromise = fetcher . fetchMany ( createBaseOpts ( ) , cancellationTokenSource . token ) ;
252- // Advance through all connectivity check delays: 1000 + 10000 + 10000 = 21000ms
253- await vi . advanceTimersByTimeAsync ( 21000 ) ;
252+ // Run all pending timers to complete all connectivity check retries
253+ await vi . runAllTimersAsync ( ) ;
254254 const result = await resultPromise ;
255255
256256 // Should fail because connectivity check never succeeded
0 commit comments