readable-stream - npm Package Compare versions

Comparing version 2.3.7 to 2.3.8

lib/_stream_readable.js

@@ -56,3 +56,3 @@ // Copyright Joyent, Inc. and other Node contributors.
 var Buffer = require('safe-buffer').Buffer;
-var OurUint8Array = global.Uint8Array || function () {};
+var OurUint8Array = (typeof global !== 'undefined' ? global : typeof window !== 'undefined' ? window : typeof self !== 'undefined' ? self : {}).Uint8Array || function () {};
 function _uint8ArrayToBuffer(chunk) {
@@ -627,4 +627,4 @@ return Buffer.from(chunk);
       if ((state.pipesCount === 1 && state.pipes === dest || state.pipesCount > 1 && indexOf(state.pipes, dest) !== -1) && !cleanedUp) {
-        debug('false write response, pause', src._readableState.awaitDrain);
-        src._readableState.awaitDrain++;
+        debug('false write response, pause', state.awaitDrain);
+        state.awaitDrain++;
         increasedAwaitDrain = true;
@@ -723,3 +723,3 @@ }
     for (var i = 0; i < len; i++) {
-      dests[i].emit('unpipe', this, unpipeInfo);
+      dests[i].emit('unpipe', this, { hasUnpiped: false });
     }return this;
@@ -726,0 +726,0 @@ }

lib/_stream_writable.js

@@ -84,3 +84,3 @@ // Copyright Joyent, Inc. and other Node contributors.
 var Buffer = require('safe-buffer').Buffer;
-var OurUint8Array = global.Uint8Array || function () {};
+var OurUint8Array = (typeof global !== 'undefined' ? global : typeof window !== 'undefined' ? window : typeof self !== 'undefined' ? self : {}).Uint8Array || function () {};
 function _uint8ArrayToBuffer(chunk) {
@@ -353,3 +353,3 @@ return Buffer.from(chunk);
 
-    if (!state.writing && !state.corked && !state.finished && !state.bufferProcessing && state.bufferedRequest) clearBuffer(this, state);
+    if (!state.writing && !state.corked && !state.bufferProcessing && state.bufferedRequest) clearBuffer(this, state);
   }
@@ -596,3 +596,3 @@ };
   // ignore unnecessary end() calls.
-  if (!state.ending && !state.finished) endWritable(this, state, cb);
+  if (!state.ending) endWritable(this, state, cb);
 };
@@ -658,7 +658,5 @@
   }
-  if (state.corkedRequestsFree) {
-    state.corkedRequestsFree.next = corkReq;
-  } else {
-    state.corkedRequestsFree = corkReq;
-  }
+
+  // reuse the free corkReq.
+  state.corkedRequestsFree.next = corkReq;
 }
@@ -665,0 +663,0 @@

lib/internal/streams/BufferList.js

@@ -59,3 +59,2 @@ 'use strict';
     if (this.length === 0) return Buffer.alloc(0);
-    if (this.length === 1) return this.head.data;
     var ret = Buffer.allocUnsafe(n >>> 0);
@@ -62,0 +61,0 @@ var p = this.head;

lib/internal/streams/destroy.js

@@ -18,5 +18,11 @@ 'use strict';
       cb(err);
-    } else if (err && (!this._writableState || !this._writableState.errorEmitted)) {
-      pna.nextTick(emitErrorNT, this, err);
+    } else if (err) {
+      if (!this._writableState) {
+        pna.nextTick(emitErrorNT, this, err);
+      } else if (!this._writableState.errorEmitted) {
+        this._writableState.errorEmitted = true;
+        pna.nextTick(emitErrorNT, this, err);
+      }
     }
+
     return this;
@@ -39,5 +45,7 @@ }
     if (!cb && err) {
-      pna.nextTick(emitErrorNT, _this, err);
-      if (_this._writableState) {
+      if (!_this._writableState) {
+        pna.nextTick(emitErrorNT, _this, err);
+      } else if (!_this._writableState.errorEmitted) {
         _this._writableState.errorEmitted = true;
+        pna.nextTick(emitErrorNT, _this, err);
       }
@@ -64,2 +72,4 @@ } else if (cb) {
     this._writableState.ending = false;
+    this._writableState.finalCalled = false;
+    this._writableState.prefinished = false;
     this._writableState.finished = false;
@@ -66,0 +76,0 @@ this._writableState.errorEmitted = false;

package.json

 {
   "name": "readable-stream",
-  "version": "2.3.7",
+  "version": "2.3.8",
   "description": "Streams3, a user-land copy of the stream library from Node.js",
@@ -5,0 +5,0 @@ "main": "readable.js",

README.md

 # readable-stream
 
-***Node-core v8.11.1 streams for userland*** [![Build Status](https://travis-ci.org/nodejs/readable-stream.svg?branch=master)](https://travis-ci.org/nodejs/readable-stream)
+***Node-core v8.17.0 streams for userland*** [![Build Status](https://travis-ci.org/nodejs/readable-stream.svg?branch=master)](https://travis-ci.org/nodejs/readable-stream)
 
@@ -21,3 +21,3 @@
 
-Full documentation may be found on the [Node.js website](https://nodejs.org/dist/v8.11.1/docs/api/stream.html).
+Full documentation may be found on the [Node.js website](https://nodejs.org/dist/v8.17.0/docs/api/stream.html).
 
@@ -24,0 +24,0 @@ If you want to guarantee a stable streams base, regardless of what version of

No alert changes

Improved metrics

Total package byte prevSize

88115

increased by0.45%

Lines of code

1928

increased by0.26%

No dependency changes