Fix code style

Author: tshemsedinov

JavaScript/1-channels.js

@@ -81,14 +81,21 @@ const job = (task, next) => {
 
 const queue = Queue.channels(3)
   .process(job)
-  .done((err, res) => {
+  .done((error, res) => {
+    if (error) console.log(`Done with error: ${error}`);
     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'));
+  .success((res) => {
+    console.log(`Success: ${res.name}`);
+  })
+  .failure((err) => {
+    console.log(`Failure: ${err}`);
+  })
+  .drain(() => {
+    console.log('Queue drain');
+  });
 
 for (let i = 0; i < 10; i++) {
   queue.add({ name: `Task${i}`, interval: i * 1000 });

JavaScript/3-pause.js

@@ -144,8 +144,12 @@ const queue = Queue.channels(3)
   .wait(4000)
   .timeout(5000)
   .process(job)
-  .success((task) => console.log(`Success: ${task.name}`))
-  .failure((err, task) => console.log(`Failure: ${err} ${task.name}`))
+  .success((task) => {
+    console.log(`Success: ${task.name}`);
+  })
+  .failure((error, task) => {
+    console.log(`Failure: ${error} ${task.name}`);
+  })
   .pause();
 
 for (let i = 0; i < 10; i++) {

JavaScript/4-priority.js

@@ -152,8 +152,13 @@ const job = (task, next) => {
 const queue = Queue.channels(3)
   .process(job)
   .priority()
-  .done((err, task) => console.log(`Done: ${task.name}`))
-  .drain(() => console.log('Queue drain'));
+  .done((error, task) => {
+    if (error) console.error(error);
+    console.log(`Done: ${task.name}`);
+  })
+  .drain(() => {
+    console.log('Queue drain');
+  });
 
 for (let i = 0; i < 10; i++) {
   queue.add({ name: `Task${i}`, interval: 1000 }, i);

JavaScript/5-pipe.js

@@ -155,7 +155,10 @@ class Queue {
 const destination = Queue.channels(2)
   .wait(5000)
   .process((task, next) => next(null, { ...task, processed: true }))
-  .done((err, task) => console.log({ task }));
+  .done((error, task) => {
+    if (error) console.error(error);
+    console.log({ task });
+  });
 
 const source = Queue.channels(3)
   .timeout(4000)

JavaScript/6-promise.js

@@ -23,15 +23,15 @@ class Queue {
   }
 
   next() {
-    const emptyChannels =  this.concurrency - this.count;
+    const emptyChannels = this.concurrency - this.count;
     let launchCount = Math.min(emptyChannels, this.waiting.length);
     while (launchCount-- > 0) {
       this.count++;
       const task = this.waiting.shift();
       this.onProcess(task)
         .then(
           (res) => void this.finish(null, res),
-          (err) => void this.finish(err)
+          (err) => void this.finish(err),
         )
         .finally(() => {
           this.count--;
@@ -91,7 +91,7 @@ const queue = Queue.channels(3)
     const { count } = queue;
     const waiting = queue.waiting.length;
     console.log(
-      `Done | res: ${res}, err: ${err}, count:${count}, waiting: ${waiting}`
+      `Done | res: ${res}, err: ${err}, count:${count}, waiting: ${waiting}`,
     );
   })
   // .success((res) => void console.log(`Success: ${res}`))

JavaScript/7-stream.js

@@ -19,7 +19,7 @@ class QueueStream extends Readable {
   }
 
   _read() {
-    const emptyChannels =  this.concurrency - this.count;
+    const emptyChannels = this.concurrency - this.count;
     let launchCount = Math.min(emptyChannels, this.waiting.length);
     while (launchCount-- > 0) {
       this.count++;

JavaScript/8-pipeline.js

@@ -19,7 +19,7 @@ class QueueStream extends Readable {
   }
 
   _read() {
-    const emptyChannels =  this.concurrency - this.count;
+    const emptyChannels = this.concurrency - this.count;
     let launchCount = Math.min(emptyChannels, this.waiting.length);
     while (launchCount-- > 0) {
       const task = this.waiting.shift();
@@ -62,7 +62,7 @@ const writable = new Writable({
   write(data, encoding, next) {
     console.log({ data });
     next();
-  }
+  },
 });
 
 const job = (task, next) => {