Improve output

Author: tshemsedinov

JavaScript/1-channels.js

@@ -73,7 +73,11 @@ const job = (task, next) => {
 
 const queue = Queue.channels(3)
   .process(job)
-  .done((err, res) => console.log(`Done: ${res.name}`))
+  .done((err, res) => {
+    const { count } = queue;
+    const waiting = queue.waiting.length;
+    console.log(`Done: ${res.name}, count:${count}, waiting: ${waiting}`);
+  })
   .success(res => console.log(`Success: ${res.name}`))
   .failure(err => console.log(`Failure: ${err}`))
   .drain(() => console.log('Queue drain'));

JavaScript/2-timeouts.js

@@ -101,15 +101,13 @@ class Queue {
 // Usage
 
 const job = (task, next) => {
-  console.log(`Process: ${task.name}`);
-  setTimeout(next, task.interval, null, task).unref();
+  setTimeout(next, task.interval, null, task);
 };
 
 const queue = Queue.channels(3)
   .wait(4000)
   .timeout(5000)
   .process(job)
-  .done((err, task) => console.log(`Done: ${task.name}`))
   .success(task => console.log(`Success: ${task.name}`))
   .failure((err, task) => console.log(`Failure: ${err} ${task.name}`))
   .drain(() => console.log('Queue drain'));

JavaScript/3-pause.js

@@ -121,18 +121,15 @@ class Queue {
 // Usage
 
 const job = (task, next) => {
-  console.log(`Process: ${task.name}`);
-  setTimeout(next, task.interval, null, task).unref();
+  setTimeout(next, task.interval, null, task);
 };
 
 const queue = Queue.channels(3)
   .wait(4000)
   .timeout(5000)
   .process(job)
-  .done((err, task) => console.log(`Done: ${task.name}`))
   .success(task => console.log(`Success: ${task.name}`))
   .failure((err, task) => console.log(`Failure: ${err} ${task.name}`))
-  .drain(() => console.log('Queue drain'))
   .pause();
 
 for (let i = 0; i < 10; i++) {

JavaScript/4-priority.js

@@ -129,21 +129,15 @@ class Queue {
 // Usage
 
 const job = (task, next) => {
-  console.log(`Process: ${task.name}`);
-  setTimeout(next, task.interval, null, task).unref();
+  setTimeout(next, task.interval, null, task);
 };
 
 const queue = Queue.channels(3)
-  .wait(4000)
-  .timeout(5000)
   .process(job)
   .priority()
   .done((err, task) => console.log(`Done: ${task.name}`))
-  .success(task => console.log(`Success: ${task.name}`))
-  .failure((err, task) => console.log(`Failure: ${err} ${task.name}`))
   .drain(() => console.log('Queue drain'));
 
 for (let i = 0; i < 10; i++) {
-  const interval = (10 - i) * 1000;
-  queue.add({ name: `Task${i}`, interval }, i);
+  queue.add({ name: `Task${i}`, interval: 1000 }, i);
 }