diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-06-04 22:37:48 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-06-04 22:39:14 +0200 |
| commit | 25a1e4708c976d848f065e097e90e13bc063e7ea (patch) | |
| tree | 157b2b0b715e6a014147c762b24b149527ef99d4 /app/relay/queue.js | |
| parent | 76c64dd94d25cd896c75bbe9d000aed7dfc33653 (diff) | |
monitoring of processes with epoch/progress events
Diffstat (limited to 'app/relay/queue.js')
| -rw-r--r-- | app/relay/queue.js | 14 |
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() |
