aboutsummaryrefslogtreecommitdiffstats
path: root/helpers/queue.js
diff options
context:
space:
mode:
Diffstat (limited to 'helpers/queue.js')
-rw-r--r--helpers/queue.js48
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
}
}