readable-stream
Advanced tools
Comparing version 2.0.2 to 2.0.3
@@ -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; |
@@ -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(_){}}()); |
{ | ||
"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": { |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
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
111736
1486