summaryrefslogtreecommitdiff
path: root/app/relay/queue.js
diff options
context:
space:
mode:
authorJules Laplace <julescarbon@gmail.com>2018-06-04 22:37:48 +0200
committerJules Laplace <julescarbon@gmail.com>2018-06-04 22:39:14 +0200
commit25a1e4708c976d848f065e097e90e13bc063e7ea (patch)
tree157b2b0b715e6a014147c762b24b149527ef99d4 /app/relay/queue.js
parent76c64dd94d25cd896c75bbe9d000aed7dfc33653 (diff)
monitoring of processes with epoch/progress events
Diffstat (limited to 'app/relay/queue.js')
-rw-r--r--app/relay/queue.js14
1 files changed, 7 insertions, 7 deletions
diff --git a/app/relay/queue.js b/app/relay/queue.js
index 6e67b80..9f9e821 100644
--- a/app/relay/queue.js
+++ b/app/relay/queue.js
@@ -2,16 +2,16 @@ let queue = []
let active = true
let status = 'waiting'
-const is_active = () => active
-const get_status = () => status
-const activate = () => {
+export const is_active = () => active
+export const get_status = () => status
+export const activate = () => {
active = true
status = 'active'
}
-const deactivate = reason => {
+export const deactivate = reason => {
active = false
status = reason
}
-const add_task = task => queue.push(task)
-const remove_task = task => queue = queue.filter(t => t.id !== task.id)
-const get_next_task = () => queue.shift()
+export const add_task = task => queue.push(task)
+export const remove_task = task => queue = queue.filter(t => t.id !== task.id)
+export const get_next_task = () => queue.shift()