consumable-stream - npm Package Compare versions

Comparing version 2.0.0 to 3.0.0

index.js

@@ -12,4 +12,13 @@ class ConsumableStream {
     if (result.done) {
-      // If stream was ended, this function should never resolve.
-      await new Promise(() => {});
+      // If stream was ended, this function should never resolve unless
+      // there is a timeout; in that case, it should reject early.
+      if (timeout == null) {
+        await new Promise(() => {});
+      } else {
+        let error = new Error(
+          'Stream consumer operation timed out early because stream ended'
+        );
+        error.name = 'TimeoutError';
+        throw error;
+      }
     }
@@ -29,1 +38,2 @@ return result.value;
 module.exports = ConsumableStream;
+

package.json

 {
   "name": "consumable-stream",
-  "version": "2.0.0",
+  "version": "3.0.0",
   "description": "A readable 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

7470

increased by4.23%

Lines of code

137

increased by7.03%

No dependency changes