readable-stream - npm Package Compare versions

Comparing version 2.0.2 to 2.0.3

lib/_stream_readable.js

@@ -21,6 +21,6 @@ 'use strict';
 
-var EE = require('events').EventEmitter;
+var EE = require('events');
 
 /*<replacement>*/
-if (!EE.listenerCount) EE.listenerCount = function(emitter, type) {
+var EElistenerCount = function(emitter, type) {
   return emitter.listeners(type).length;
@@ -52,5 +52,6 @@ };
 /*<replacement>*/
-var debug = require('util');
-if (debug && debug.debuglog) {
-  debug = debug.debuglog('stream');
+var debugUtil = require('util');
+var debug;
+if (debugUtil && debugUtil.debuglog) {
+  debug = debugUtil.debuglog('stream');
 } else {
@@ -224,3 +225,2 @@ debug = function () {};
 
-
 // if it's past the high water mark, we can push in some more.
@@ -249,5 +249,5 @@ // Also, if we have no data yet, we can stand some
 
-// Don't raise the hwm > 128MB
+// Don't raise the hwm > 8MB
 var MAX_HWM = 0x800000;
-function roundUpToNextPowerOf2(n) {
+function computeNewHighWaterMark(n) {
   if (n >= MAX_HWM) {
@@ -258,3 +258,7 @@ n = MAX_HWM;
     n--;
-    for (var p = 1; p < 32; p <<= 1) n |= n >> p;
+    n |= n >>> 1;
+    n |= n >>> 2;
+    n |= n >>> 4;
+    n |= n >>> 8;
+    n |= n >>> 16;
     n++;
@@ -288,3 +292,3 @@ }
   if (n > state.highWaterMark)
-    state.highWaterMark = roundUpToNextPowerOf2(n);
+    state.highWaterMark = computeNewHighWaterMark(n);
 
@@ -595,3 +599,3 @@ // don't have that much.  return null, unless we've ended.
     dest.removeListener('error', onerror);
-    if (EE.listenerCount(dest, 'error') === 0)
+    if (EElistenerCount(dest, 'error') === 0)
       dest.emit('error', er);
@@ -609,3 +613,2 @@ }
 
-
   // Both close and finish should trigger unpipe, but only once.
@@ -647,3 +650,3 @@ function onclose() {
       state.awaitDrain--;
-    if (state.awaitDrain === 0 && EE.listenerCount(src, 'data')) {
+    if (state.awaitDrain === 0 && EElistenerCount(src, 'data')) {
       state.flowing = true;
@@ -864,3 +867,2 @@ flow(src);
 
-
 // exposed for testing purposes only.
@@ -867,0 +869,0 @@ Readable._fromList = fromList;

lib/_stream_writable.js

@@ -27,3 +27,10 @@ // A bit simpler than readable streams.
 
+/*<replacement>*/
+var internalUtil = {
+  deprecate: require('util-deprecate')
+};
+/*</replacement>*/
 
+
+
 /*<replacement>*/
@@ -153,6 +160,6 @@ var Stream;
 Object.defineProperty(WritableState.prototype, 'buffer', {
-  get: require('util-deprecate')(function() {
+  get: internalUtil.deprecate(function() {
     return this.getBuffer();
-  }, '_writableState.buffer is deprecated. Use ' +
-      '_writableState.getBuffer() instead.')
+  }, '_writableState.buffer is deprecated. Use _writableState.getBuffer ' +
+     'instead.')
 });
@@ -159,0 +166,0 @@ }catch(_){}}());

package.json

 {
   "name": "readable-stream",
-  "version": "2.0.2",
+  "version": "2.0.3",
   "description": "Streams3, a user-land copy of the stream library from iojs v2.x",
@@ -21,3 +21,4 @@ "main": "readable.js",
     "test": "tap test/parallel/*.js",
-    "browser": "zuul --browser-name $BROWSER_NAME --browser-version $BROWSER_VERSION -- test/browser.js"
+    "browser": "npm run write-zuul && zuul -- test/browser.js",
+    "write-zuul": "printf \"ui: tape\nbrowsers:\n  - name: $BROWSER_NAME\n    version: $BROWSER_VERSION\n\">.zuul.yml"
   },
@@ -24,0 +25,0 @@ "repository": {

No alert changes

Improved metrics

Total package byte prevSize

111736

increased by2.06%

Lines of code

1486

increased by0.68%

No dependency changes