diff options
Diffstat (limited to 'helpers/queue.js')
-rw-r--r-- | helpers/queue.js | 48 |
1 files changed, 24 insertions, 24 deletions
diff --git a/helpers/queue.js b/helpers/queue.js index 69e708a..6a9148d 100644 --- a/helpers/queue.js +++ b/helpers/queue.js @@ -1,7 +1,7 @@ class Queue { - static queue = []; - static pendingPromise = false; - static stop = false; + static queue = [] + static pendingPromise = false + static stop = false static enqueue(promise) { return new Promise((resolve, reject) => { @@ -9,44 +9,44 @@ class Queue { promise, resolve, reject - }); - this.dequeue(); - }); + }) + this.dequeue() + }) } static dequeue() { if (this.workingOnPromise) { - return false; + return false } if (this.stop) { - this.queue = []; - this.stop = false; - return; + this.queue = [] + this.stop = false + return } - const item = this.queue.shift(); + const item = this.queue.shift() if (!item) { - return false; + return false } try { - this.workingOnPromise = true; + this.workingOnPromise = true item .promise() .then((value) => { - this.workingOnPromise = false; - item.resolve(value); - this.dequeue(); + this.workingOnPromise = false + item.resolve(value) + this.dequeue() }) .catch((err) => { - this.workingOnPromise = false; - item.reject(err); - this.dequeue(); - }); + this.workingOnPromise = false + item.reject(err) + this.dequeue() + }) } catch (err) { - this.workingOnPromise = false; - item.reject(err); - this.dequeue(); + this.workingOnPromise = false + item.reject(err) + this.dequeue() } - return true; + return true } } |