aboutsummaryrefslogtreecommitdiffstats
path: root/helpers/queue.js
diff options
context:
space:
mode:
authorGravatar piotrruss <mail@pruss.it> 2021-09-06 23:13:22 +0200
committerGravatar piotrruss <mail@pruss.it> 2021-09-06 23:13:22 +0200
commit569bdb8c5d7538fa0ea8a99ff2f8376f7cbfa51a (patch)
tree8d1cb94a56d60b9d726222277b7516fc59895613 /helpers/queue.js
parent275bd1d0a9aea90696c145cf992d522a0d6b0aa8 (diff)
downloadmy_apps-569bdb8c5d7538fa0ea8a99ff2f8376f7cbfa51a.tar.gz
my_apps-569bdb8c5d7538fa0ea8a99ff2f8376f7cbfa51a.tar.bz2
my_apps-569bdb8c5d7538fa0ea8a99ff2f8376f7cbfa51a.zip
added stadard linter
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
}
}