From 76b9cb6b0cbc96a639c212076a87e7322c2a47e6 Mon Sep 17 00:00:00 2001 From: Dragory Date: Sat, 23 Feb 2019 21:19:46 +0200 Subject: [PATCH] Queue: allow overriding queue timeout --- src/Queue.ts | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/src/Queue.ts b/src/Queue.ts index 19969792..a3e519bb 100644 --- a/src/Queue.ts +++ b/src/Queue.ts @@ -1,9 +1,15 @@ type QueueFn = (...args: any[]) => Promise; +const DEFAULT_TIMEOUT = 10 * 1000; + export class Queue { protected running: boolean = false; protected queue: QueueFn[] = []; - protected timeout: number = 10 * 1000; + protected timeout: number; + + constructor(timeout = DEFAULT_TIMEOUT) { + this.timeout = timeout; + } public add(fn) { const promise = new Promise(resolve => {