Comparing version 2.11.1 to 2.11.2
@@ -298,4 +298,4 @@ const { EventEmitter } = require('events') | ||
const data = this.shift() | ||
if (this.pipeTo !== null && this.pipeTo.write(data) === false) stream._duplexState &= READ_PIPE_NOT_DRAINED | ||
if ((stream._duplexState & READ_EMIT_DATA) !== 0) stream.emit('data', data) | ||
if (this.pipeTo !== null && this.pipeTo.write(data) === false) stream._duplexState &= READ_PIPE_NOT_DRAINED | ||
return data | ||
@@ -312,4 +312,4 @@ } | ||
const data = this.shift() | ||
if (this.pipeTo !== null && this.pipeTo.write(data) === false) stream._duplexState &= READ_PIPE_NOT_DRAINED | ||
if ((stream._duplexState & READ_EMIT_DATA) !== 0) stream.emit('data', data) | ||
if (this.pipeTo !== null && this.pipeTo.write(data) === false) stream._duplexState &= READ_PIPE_NOT_DRAINED | ||
} | ||
@@ -316,0 +316,0 @@ } |
{ | ||
"name": "streamx", | ||
"version": "2.11.1", | ||
"version": "2.11.2", | ||
"description": "An iteration of the Node.js core streams with a series of improvements", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package