Comparing version 2.6.2 to 2.6.3
12
index.js
@@ -110,2 +110,6 @@ const { EventEmitter } = require('events') | ||
get ended () { | ||
return (this.stream._duplexState & WRITE_DONE) !== 0 | ||
} | ||
push (data) { | ||
@@ -212,2 +216,6 @@ if (this.map !== null) data = this.map(data) | ||
get ended () { | ||
return (this.stream._duplexState & READ_DONE) !== 0 | ||
} | ||
pipe (pipeTo, cb) { | ||
@@ -526,7 +534,7 @@ if (this.pipeTo !== null) throw new Error('Can only pipe to one destination') | ||
get readable () { | ||
return this._readableState !== null | ||
return this._readableState !== null ? true : undefined | ||
} | ||
get writable () { | ||
return this._writableState !== null | ||
return this._writableState !== null ? true : undefined | ||
} | ||
@@ -533,0 +541,0 @@ |
{ | ||
"name": "streamx", | ||
"version": "2.6.2", | ||
"version": "2.6.3", | ||
"description": "An iteration of the Node.js core streams with a series of improvements", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
50937
1300