writable-consumable-stream - npm Package Compare versions

Comparing version 1.0.1 to 1.0.2

index.js

@@ -122,3 +122,11 @@ const ConsumableStream = require('consumable-stream');
 
-  getConsumerStats() {
+  getConsumerStats(consumerId) {
+    let consumer = this._consumers[consumerId];
+    if (consumer) {
+      return consumer.getStats();
+    }
+    return undefined;
+  }
+
+  getAllConsumerStats() {
     let consumerStats = [];
@@ -125,0 +133,0 @@ let consumerList = Object.values(this._consumers);

package.json

 {
   "name": "writable-consumable-stream",
-  "version": "1.0.1",
+  "version": "1.0.2",
   "description": "An async stream which can be iterated over using a for-await-of loop.",
@@ -5,0 +5,0 @@ "main": "index.js",

test/test.js

@@ -666,3 +666,3 @@ const WritableConsumableStream = require('../index');
         (async () => {
-          let consumerStats = stream.getConsumerStats();
+          let consumerStats = stream.getAllConsumerStats();
           assert.equal(consumerStats.length, 0);
@@ -672,3 +672,3 @@
 
-          consumerStats = stream.getConsumerStats();
+          consumerStats = stream.getAllConsumerStats();
           assert.equal(consumerStats.length, 1);
@@ -683,3 +683,3 @@ assert.equal(consumerStats[0].backpressure, 0);
 
-          consumerStats = stream.getConsumerStats();
+          consumerStats = stream.getAllConsumerStats();
           assert.equal(consumerStats.length, 1);
@@ -690,3 +690,3 @@ assert.equal(consumerStats[0].backpressure, 1);
 
-          consumerStats = stream.getConsumerStats();
+          consumerStats = stream.getAllConsumerStats();
           assert.equal(consumerStats.length, 1);
@@ -697,3 +697,3 @@ assert.equal(consumerStats[0].backpressure, 0);
 
-          consumerStats = stream.getConsumerStats();
+          consumerStats = stream.getAllConsumerStats();
           assert.equal(consumerStats.length, 1);
@@ -709,3 +709,3 @@ assert.equal(consumerStats[0].backpressure, 1);
 
-          consumerStats = stream.getConsumerStats();
+          consumerStats = stream.getAllConsumerStats();
           assert.equal(consumerStats.length, 1);
@@ -716,3 +716,3 @@ assert.equal(consumerStats[0].backpressure, 4);
 
-          consumerStats = stream.getConsumerStats();
+          consumerStats = stream.getAllConsumerStats();
           assert.equal(consumerStats.length, 1);
@@ -726,7 +726,7 @@ assert.equal(consumerStats[0].backpressure, 5);
             await wait(70);
-            let consumerStats = stream.getConsumerStats();
+            let consumerStats = stream.getAllConsumerStats();
             assert.equal(consumerStats.length, 1);
             assert.equal(consumerStats[0].backpressure, expectedPressure);
           }
-          let consumerStats = stream.getConsumerStats();
+          let consumerStats = stream.getAllConsumerStats();
           assert.equal(consumerStats.length, 0);
@@ -745,3 +745,3 @@ })()
             stream.write('a' + i);
-            let consumerStats = stream.getConsumerStats();
+            let consumerStats = stream.getAllConsumerStats();
             assert.equal(consumerStats.length, 1);
@@ -762,3 +762,3 @@ assert.equal(consumerStats[0].backpressure, i + 1);
             let data = await iter.next();
-            let consumerStats = stream.getConsumerStats();
+            let consumerStats = stream.getAllConsumerStats();
 
@@ -782,3 +782,3 @@ if (data.done) {
 
-      let consumerStats = stream.getConsumerStats();
+      let consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 1);
@@ -789,3 +789,3 @@ assert.equal(consumerStats[0].backpressure, 0);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 1);
@@ -796,3 +796,3 @@ assert.equal(consumerStats[0].backpressure, 0);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 1);
@@ -813,3 +813,3 @@ assert.equal(consumerStats[0].backpressure, 1);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 2);
@@ -827,3 +827,3 @@ assert.equal(consumerStats[0].backpressure, 5);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 2);
@@ -835,3 +835,3 @@ assert.equal(consumerStats[0].backpressure, 4);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 2);
@@ -844,3 +844,3 @@ assert.equal(consumerStats[0].backpressure, 2);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 2);
@@ -852,3 +852,3 @@ assert.equal(consumerStats[0].backpressure, 5);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 2);
@@ -868,3 +868,3 @@ assert.equal(consumerStats[0].backpressure, 6);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 2);
@@ -885,3 +885,3 @@ assert.equal(consumerStats[0].backpressure, 1);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 1);
@@ -894,3 +894,3 @@ assert.equal(consumerStats[0].backpressure, 1);
 
-      consumerStats = stream.getConsumerStats();
+      consumerStats = stream.getAllConsumerStats();
       assert.equal(consumerStats.length, 0);
@@ -897,0 +897,0 @@ assert.equal(iterAData.done, true);

No alert changes

Improved metrics

Total package byte prevSize

51769

increased by0.46%

Lines of code

1361

increased by0.52%

No dependency changes