improves queueProcessor

This commit is contained in:
abhinav-grd 2021-09-12 15:56:16 +05:30
parent e411eeaa4e
commit b3a9c8ee94

View file

@ -5,7 +5,7 @@ interface RequestQueueItem {
canceller: { exec: () => void };
}
interface RequestCanceller {
export interface RequestCanceller {
exec: () => void;
}
@ -16,7 +16,9 @@ export default class QueueProcessor<T> {
constructor(private maxParallelProcesses: number) {}
public queueUpRequest(request: () => Promise<T>) {
public queueUpRequest(
request: (canceller?: RequestCanceller) => Promise<T>
) {
const isCanceled = { status: false };
const canceller: RequestCanceller = {
exec: () => {