0ct0pu5/ente
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Remove unused knob

Browse source
This commit is contained in:
Manav Rathi 2024-04-05 09:08:56 +05:30
parent 1d0f30ad91
commit a68dce35f6
No known key found for this signature in database
1 changed files with 1 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
web/packages/shared/utils/queueProcessor.ts
View file

@ -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<T> {
private requestInProcessing = 0;
private maxParallelProcesses = 1;
private processingStrategy = PROCESSING_STRATEGY.FIFO;
public queueUpRequest(
request: (canceller?: RequestCanceller) => Promise<T>,
@ -61,10 +55,7 @@ export default class QueueProcessor<T> {
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) {