stream-demux - npm Package Compare versions

Comparing version 8.0.0 to 8.1.0

index.js

@@ -115,2 +115,10 @@ const WritableConsumableStream = require('writable-consumable-stream');
 
+  getConsumerCount(streamName) {
+    return this.getConsumerStatsList(streamName).length;
+  }
+
+  getConsumerCountAll() {
+    return this.getConsumerStatsListAll().length;
+  }
+
   createConsumer(streamName, timeout) {
@@ -117,0 +125,0 @@ let mainStreamConsumer = this._mainStream.createConsumer(timeout);

package.json

 {
   "name": "stream-demux",
-  "version": "8.0.0",
+  "version": "8.1.0",
   "description": "A consumable stream demultiplexer.",
@@ -32,4 +32,4 @@ "main": "index.js",
     "consumable-stream": "^2.0.0",
-    "writable-consumable-stream": "^2.0.0"
+    "writable-consumable-stream": "^3.0.1"
   }
 }

README.md

@@ -46,3 +46,3 @@ # stream-demux
   // createConsumer(n) method to force the iteration to
-  // timeout after n milliseconds of innactivity.
+  // timeout after n milliseconds of inactivity.
   let consumer = demux.stream('def').createConsumer();
@@ -49,0 +49,0 @@ while (true) {

No alert changes

Improved metrics

Total package byte prevSize

30994

0.57%

Lines of code

739

0.82%

Dependency changes

• + Added

  writable-consumable-stream@3.0.1
  (transitive)

• - Removed

  writable-consumable-stream@2.0.0
  (transitive)

• Updated

  writable-consumable-stream@^3.0.1