From b3a9c8ee94c5606f162c4c1691a7c02198fbfd84 Mon Sep 17 00:00:00 2001 From: abhinav-grd Date: Sun, 12 Sep 2021 15:56:16 +0530 Subject: [PATCH] improves queueProcessor --- src/services/upload/queueProcessor.ts | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/services/upload/queueProcessor.ts b/src/services/upload/queueProcessor.ts index b825b8f21..ae6ec39b1 100644 --- a/src/services/upload/queueProcessor.ts +++ b/src/services/upload/queueProcessor.ts @@ -5,7 +5,7 @@ interface RequestQueueItem { canceller: { exec: () => void }; } -interface RequestCanceller { +export interface RequestCanceller { exec: () => void; } @@ -16,7 +16,9 @@ export default class QueueProcessor { constructor(private maxParallelProcesses: number) {} - public queueUpRequest(request: () => Promise) { + public queueUpRequest( + request: (canceller?: RequestCanceller) => Promise + ) { const isCanceled = { status: false }; const canceller: RequestCanceller = { exec: () => {