diff options
| author | Jules Laplace <julescarbon@gmail.com> | 2018-05-28 10:18:25 +0200 |
|---|---|---|
| committer | Jules Laplace <julescarbon@gmail.com> | 2018-05-28 10:18:25 +0200 |
| commit | 3a8d99c5e4f64a9426585943c40635eb183b47ae (patch) | |
| tree | d09bc57d59ec0ff7a6def8af49634c4aab64e493 /app/client/socket/socket.task.js | |
| parent | ed80103ff0c4b87d2726da5ceab8ec566b46e0ee (diff) | |
start/stop tasks
Diffstat (limited to 'app/client/socket/socket.task.js')
| -rw-r--r-- | app/client/socket/socket.task.js | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/app/client/socket/socket.task.js b/app/client/socket/socket.task.js index ba074c0..595066e 100644 --- a/app/client/socket/socket.task.js +++ b/app/client/socket/socket.task.js @@ -11,14 +11,14 @@ socket.on('task_res', (data) => { case 'start': // return dispatch({ type: types.system.rpc_connected, runner: data.runner }) break - case 'task_begin': - clearTimeout(finishTimeout) - return dispatch({ type: types.task.task_begin, task: data.task }) - break case 'stop': break + // begin and finish calls often arrive out of order, if the old task was preempted + case 'task_begin': + dispatch({ type: types.task.task_begin, task: data.task }) + break case 'task_finish': - return finishTimeout = setTimeout(() => dispatch({ type: types.task.task_finish, task: data.task }), 100) + dispatch({ type: types.task.task_finish, task: data.task }) break case 'kill': break |
