streamx - npm Package Compare versions

Comparing version 2.20.1 to 2.20.2

index.js

		@@ -74,3 +74,3 @@ const { EventEmitter } = require('events')
		const WRITE_NON_PRIMARY = MAX ^ WRITE_PRIMARY
		const WRITE_NOT_FINISHING = MAX ^ WRITE_FINISHING
		const WRITE_NOT_FINISHING = MAX ^ (WRITE_ACTIVE \| WRITE_FINISHING)
		const WRITE_DRAINED = MAX ^ WRITE_UNDRAINED
		@@ -114,2 +114,3 @@ const WRITE_NOT_QUEUED = MAX ^ WRITE_QUEUED
		const WRITE_UPDATE_SYNC_STATUS = WRITE_UPDATING \| OPEN_STATUS \| WRITE_NEXT_TICK \| WRITE_PRIMARY
		const WRITE_DROP_DATA = WRITE_FINISHING \| WRITE_DONE \| DESTROY_STATUS

		@@ -138,2 +139,3 @@ const asyncIterator = Symbol.asyncIterator \|\| Symbol('asyncIterator')
		push (data) {
		if ((this.stream._duplexState & WRITE_DROP_DATA) !== 0) return false
		if (this.map !== null) data = this.map(data)
		@@ -203,3 +205,3 @@
		if ((stream._duplexState & WRITE_FINISHING_STATUS) === WRITE_FINISHING) {
		stream._duplexState = (stream._duplexState \| WRITE_ACTIVE) & WRITE_NOT_FINISHING
		stream._duplexState = stream._duplexState \| WRITE_ACTIVE
		stream._final(afterFinal.bind(this))
		@@ -496,3 +498,3 @@ return

		stream._duplexState &= WRITE_NOT_ACTIVE
		stream._duplexState &= WRITE_NOT_FINISHING

		@@ -499,0 +501,0 @@ // no need to wait the extra tick here, so we short circuit that

package.json

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

New alerts