diff --git a/web/packages/shared/utils/queueProcessor.ts b/web/packages/shared/utils/queueProcessor.ts index d9eebfd19..29842d295 100644 --- a/web/packages/shared/utils/queueProcessor.ts +++ b/web/packages/shared/utils/queueProcessor.ts @@ -8,11 +8,6 @@ interface RequestQueueItem { canceller: { exec: () => void }; } -export enum PROCESSING_STRATEGY { - FIFO, - LIFO, -} - export interface RequestCanceller { exec: () => void; } @@ -26,7 +21,6 @@ export default class QueueProcessor { private requestInProcessing = 0; private maxParallelProcesses = 1; - private processingStrategy = PROCESSING_STRATEGY.FIFO; public queueUpRequest( request: (canceller?: RequestCanceller) => Promise, @@ -61,10 +55,7 @@ export default class QueueProcessor { private async processQueue() { while (this.requestQueue.length > 0) { - const queueItem = - this.processingStrategy === PROCESSING_STRATEGY.LIFO - ? this.requestQueue.pop() - : this.requestQueue.shift(); + const queueItem = this.requestQueue.shift(); let response = null; if (queueItem.isCanceled.status) {