add mediator package

Signed-off-by: Nimit <nimitagg95@gmail.com>

Author: nimit95

Behavioral/mediator.js

@@ -0,0 +1,38 @@
+const cluster = require('cluster');
+if (cluster.isMaster) {
+ // Mediate between master class and forks
+ class MasterProcessMediator {
+ constructor() {
+ this.forks = [];
+ }
+ init() {
+ const worker = cluster.fork();
+ this.forks.push(worker);
+ // 
+ worker.on('message', 
+ (() => (message) => this.handleMessageFromWorker(worker.id, message))()
+ );
+ }
+ 
+ // handler for various workers
+ handleMessageFromWorker(workerId, message) {
+ console.log("Worker " + workerId + " says hi with msg " + message);
+ }
+ 
+ notifyAllWorker() {
+ this.forks.map(fork => fork.send("received Msg"));
+ }
+ }
+
+ const mediator = new MasterProcessMediator();
+ mediator.init();
+
+ mediator.notifyAllWorker();
+} else {
+ process.on('message', (message) => {
+ console.log(cluster.worker.id + " " + message);
+ });
+ process.send("working");
+ setTimeout(() => process.kill(process.pid), 0);
+}
+

buildDocs.js

@@ -33,6 +33,7 @@ const sections = [
  { name: 'chainOfResponsibility', path: './Behavioral' },
  { name: 'command', path: './Behavioral' },
  { name: 'iterator', path: './Behavioral' },
+ { name: 'mediator', path: './Behavioral' },
  ]
  }
 ];

docs.md

@@ -20,6 +20,7 @@
 * [Chain Of Responsibility](#chain-of-responsibility)
 * [Command](#command)
 * [Iterator](#iterator)
+* [Mediator](#mediator)
 
 
 
@@ -780,5 +781,49 @@ function totalSize(iterator) {
 console.log(totalSize(new FileBufferIterator(__dirname)));
 ```
 
+### Mediator
+##### mediator.js
+```Javascript
+const cluster = require('cluster');
+if (cluster.isMaster) {
+ // Mediate between master class and forks
+ class MasterProcessMediator {
+ constructor() {
+ this.forks = [];
+ }
+ init() {
+ const worker = cluster.fork();
+ this.forks.push(worker);
+ // 
+ worker.on('message', 
+ (() => (message) => this.handleMessageFromWorker(worker.id, message))()
+ );
+ }
+ 
+ // handler for various workers
+ handleMessageFromWorker(workerId, message) {
+ console.log("Worker " + workerId + " says hi with msg " + message);
+ }
+ 
+ notifyAllWorker() {
+ this.forks.map(fork => fork.send("received Msg"));
+ }
+ }
+
+ const mediator = new MasterProcessMediator();
+ mediator.init();
+
+ mediator.notifyAllWorker();
+} else {
+ process.on('message', (message) => {
+ console.log(cluster.worker.id + " " + message);
+ });
+ process.send("working");
+ setTimeout(() => process.kill(process.pid), 0);
+}
+
+
+```
+