streamx - npm Package Compare versions

Comparing version 2.11.3 to 2.12.0

index.js

@@ -606,2 +606,3 @@ const { EventEmitter } = require('events')
       if (opts.read) this._read = opts.read
+      if (opts.eagerOpen) this.resume().pause()
     }
@@ -608,0 +609,0 @@ }

package.json

 {
   "name": "streamx",
-  "version": "2.11.3",
+  "version": "2.12.0",
   "description": "An iteration of the Node.js core streams with a series of improvements",
@@ -5,0 +5,0 @@ "main": "index.js",

README.md

@@ -113,3 +113,4 @@ # streamx
   byteLength: (data) => size, // optional function that calculates the byte size of input data
-  signal: abortController.signal // optional AbortSignal that triggers `.destroy` when on `abort`
+  signal: abortController.signal, // optional AbortSignal that triggers `.destroy` when on `abort`
+  eagerOpen: false // eagerly open the stream
 }
@@ -116,0 +117,0 @@ ```

test/readable.js

@@ -66,2 +66,33 @@ const tape = require('tape')
 
+tape('lazy open', async function (t) {
+  let opened = false
+  const r = new Readable({
+    open (cb) {
+      opened = true
+      cb(null)
+    }
+  })
+  await nextImmediate()
+  t.notOk(opened)
+  r.push(null)
+  await nextImmediate()
+  t.ok(opened)
+  t.end()
+})
+
+tape('eager open', async function (t) {
+  let opened = false
+  const r = new Readable({
+    open (cb) {
+      opened = true
+      cb(null)
+    },
+    eagerOpen: true
+  })
+  await nextImmediate()
+  t.ok(opened)
+  r.push(null)
+  t.end()
+})
+
 tape('shorthands', function (t) {
@@ -68,0 +99,0 @@ t.plan(3 + 1)

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

66795

increased by0.87%

Lines of code

1792

increased by1.7%

Number of lines in readme file

464

increased by0.22%

No dependency changes