Pass max size to task easy queues (#55)

* Pass max size to task easy queues * 1.2.5
cmseaton42 · Sep 3, 2019 · a5788f3 · a5788f3
1 parent def4e93
commit a5788f3
Show file tree

Hide file tree

Showing 4 changed files with 42 additions and 18 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "ethernet-ip",
-    "version": "1.2.4",
+    "version": "1.2.5",
     "description": "A simple node interface for Ethernet/IP.",
     "main": "./src/index.js",
     "scripts": {

diff --git a/src/controller/controller.spec.js b/src/controller/controller.spec.js
@@ -49,5 +49,10 @@ describe("Controller Class", () => {
 
             expect(plc.time).toMatchSnapshot();
         });
+
+        it("Task Easy", () => {
+            const plc = new Controller({ queue_max_size: 200 });
+            expect(plc.workers.read.max).toEqual(200);
+        });
     });
 });
diff --git a/src/controller/index.js b/src/controller/index.js
@@ -11,9 +11,9 @@ const compare = (obj1, obj2) => {
 };
 
 class Controller extends ENIP {
-    constructor() {
+    constructor({ queue_max_size } = {}) {
         super();
-
+        
         this.state = {
             ...this.state,
             controller: {
@@ -37,9 +37,9 @@ class Controller extends ENIP {
         };
 
         this.workers = {
-            read: new Queue(compare),
-            write: new Queue(compare),
-            group: new Queue(compare)
+            read: new Queue(compare, queue_max_size),
+            write: new Queue(compare, queue_max_size),
+            group: new Queue(compare, queue_max_size)
         };
     }