writable-consumable-stream - npm Package Compare versions

Comparing version 1.0.0 to 1.0.1

consumer.js

@@ -11,2 +11,13 @@ class Consumer {
 
+  getStats() {
+    let stats = {
+      id: this.id,
+      backpressure: this.backpressure
+    };
+    if (this.timeout != null) {
+      stats.timeout = this.timeout;
+    }
+    return stats;
+  }
+
   async next() {
@@ -13,0 +24,0 @@ this.stream.setConsumer(this.id, this);

index.js

@@ -128,6 +128,3 @@ const ConsumableStream = require('consumable-stream');
       let consumer = consumerList[i];
-      consumerStats.push({
-        id: consumer.id,
-        backpressure: consumer.backpressure
-      });
+      consumerStats.push(consumer.getStats());
     }
@@ -134,0 +131,0 @@ return consumerStats;

package.json

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

No alert changes

Improved metrics

Total package byte prevSize

51532

increased by0.26%

Lines of code

1354

increased by0.52%

No dependency changes