@@ -206,9 +206,6 @@ export class AsyncQueue {
206
206
// assertion sanity-checks.
207
207
private operationInProgress = false ;
208
208
209
- // List of TimerIds to fast-forward delays for.
210
- private timerIdsToSkip : TimerId [ ] = [ ] ;
211
-
212
209
// Is this AsyncQueue being shut down? If true, this instance will not enqueue
213
210
// any new operations, Promises from enqueue requests will not resolve.
214
211
get isShuttingDown ( ) : boolean {
@@ -335,15 +332,6 @@ export class AsyncQueue {
335
332
) ;
336
333
this . delayedOperations . push ( delayedOp as DelayedOperation < unknown > ) ;
337
334
338
- // Fast-forward delays for timerIds that have been overriden.
339
- for ( const timerIdToSkip of this . timerIdsToSkip ) {
340
- if ( this . containsDelayedOperation ( timerIdToSkip ) ) {
341
- this . runDelayedOperationsEarly ( timerIdToSkip )
342
- . then ( ( ) => { } )
343
- . catch ( ( ) => 'obligatory catch' ) ;
344
- }
345
- }
346
-
347
335
return delayedOp ;
348
336
}
349
337
@@ -422,13 +410,6 @@ export class AsyncQueue {
422
410
} ) ;
423
411
}
424
412
425
- /**
426
- * For Tests: Skip all delays for a timer id.
427
- */
428
- skipDelaysForTimerId ( timerId : TimerId ) : void {
429
- this . timerIdsToSkip . push ( timerId ) ;
430
- }
431
-
432
413
/** Called once a DelayedOperation is run or canceled. */
433
414
private removeDelayedOperation ( op : DelayedOperation < unknown > ) : void {
434
415
// NOTE: indexOf / slice are O(n), but delayedOperations is expected to be small.
0 commit comments