Add space events

erayd · Jan 2, 2020 · 8742f7d · 8742f7d
1 parent c660a4b
commit 8742f7d
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -133,3 +133,6 @@ The queue is full.
 
 #### empty
 The queue is empty.
+
+#### space
+The queue has space available to store more items.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "spique",
-  "version": "2.1.0",
+  "version": "2.2.0",
   "description": "A spiral deque - high performance and dynamic queue size",
   "main": "spique.js",
   "scripts": {

diff --git a/ringbuffer.js b/ringbuffer.js
@@ -73,6 +73,8 @@ module.exports = class Ringbuffer extends events.EventEmitter {
       buffer[pos] = undefined;
       if (this.isEmpty())
         this.emit("empty", this);
+      if (items < size)
+        this.emit("space", this);
       return value;
     };
 
@@ -87,6 +89,8 @@ module.exports = class Ringbuffer extends events.EventEmitter {
       items--;
       if (this.isEmpty())
         this.emit("empty", this);
+      if (items < size)
+        this.emit("space", this);
       return value;
     };
 

diff --git a/spique.js b/spique.js
@@ -121,6 +121,8 @@ module.exports = class Spique extends events.EventEmitter {
       items--;
       if (items === 0)
         this.emit("empty", this);
+      if (items < maxItems)
+        this.emit("space", this);
       return value;
     };
 
@@ -137,6 +139,8 @@ module.exports = class Spique extends events.EventEmitter {
       items--;
       if (items === 0)
         this.emit("empty", this);
+      if (items < maxItems)
+        this.emit("space", this);
       return value;
     };