understream - npm Package Compare versions

Comparing version 0.10.14 to 0.11.0

lib-js/helpers.js

@@ -11,3 +11,4 @@ // Generated by CoffeeScript 1.6.3
     return (instance != null) && _.isObject(instance) && instance instanceof EventEmitter && (instance.pipe != null) && ((instance._read != null) || (instance.read != null) || instance.readable);
-  }
+  },
+  DEFAULT_MAX_LISTENERS: 10
 };

lib-js/transforms/join.js

@@ -159,3 +159,3 @@ // Generated by CoffeeScript 1.6.3
   ended = function(stream) {
-    return stream._readableState.ended && _.isEmpty(stream._readableState.buffer);
+    return stream._readableState.ended && stream._readableState.buffer.length === 0;
   };
@@ -162,0 +162,0 @@

lib-js/understream.js

 // Generated by CoffeeScript 1.6.3
-var ArrayStream, DevNull, EventEmitter, PassThrough, Readable, StreamCombiner, Transform, Understream, Writable, add_listener_unsafe, add_reporter, debug, domain, domainify, fs, is_readable, pipe_streams_together, pipeline_of_streams, state_to_string, to_report_string, _, _ref,
+var ArrayStream, DEFAULT_MAX_LISTENERS, DevNull, EventEmitter, PassThrough, Readable, StreamCombiner, Transform, Understream, Writable, add_listener_unsafe, add_reporter, debug, domain, domainify, fs, is_readable, pipe_streams_together, pipeline_of_streams, state_to_string, to_report_string, _, _ref, _ref1,
   __slice = [].slice,
@@ -22,3 +22,3 @@ __bind = function(fn, me){ return function(){ return fn.apply(me, arguments); }; },
 
-is_readable = require('./helpers').is_readable;
+_ref1 = require('./helpers'), is_readable = _ref1.is_readable, DEFAULT_MAX_LISTENERS = _ref1.DEFAULT_MAX_LISTENERS;
 
@@ -28,2 +28,4 @@ add_listener_unsafe = function(emitter, event, listener) {
     emitter.setMaxListeners(emitter._maxListeners + 1);
+  } else {
+    emitter._maxListeners = DEFAULT_MAX_LISTENERS + 1;
   }
@@ -90,3 +92,3 @@ return emitter.addListener(event, listener);
 pipe_streams_together = function() {
-  var i, streams, _i, _ref1, _results;
+  var i, streams, _i, _ref2, _results;
   streams = 1 <= arguments.length ? __slice.call(arguments, 0) : [];
@@ -97,3 +99,3 @@ if (streams.length < 2) {
   _results = [];
-  for (i = _i = 0, _ref1 = streams.length - 2; 0 <= _ref1 ? _i <= _ref1 : _i >= _ref1; i = 0 <= _ref1 ? ++_i : --_i) {
+  for (i = _i = 0, _ref2 = streams.length - 2; 0 <= _ref2 ? _i <= _ref2 : _i >= _ref2; i = 0 <= _ref2 ? ++_i : --_i) {
     _results.push(streams[i].pipe(streams[i + 1]));
@@ -148,4 +150,10 @@ }
   ArrayStream.prototype._read = function(size) {
-    debug("_read " + size + " " + (JSON.stringify(this.arr[this.index])));
-    this.push(this.arr[this.index]);
+    var data;
+    if (this.index > (this.arr.length - 1)) {
+      this.push(null);
+      return;
+    }
+    data = this.arr[this.index];
+    debug("_read " + size + " " + (JSON.stringify(data)));
+    this.push(data);
     return this.index += 1;
@@ -240,5 +248,5 @@ };
   Understream.prototype.readable = function() {
-    var last, streams, _i, _ref1;
+    var last, streams, _i, _ref2;
     pipe_streams_together.apply(null, this._streams);
-    _ref1 = this._streams, streams = 2 <= _ref1.length ? __slice.call(_ref1, 0, _i = _ref1.length - 1) : (_i = 0, []), last = _ref1[_i++];
+    _ref2 = this._streams, streams = 2 <= _ref2.length ? __slice.call(_ref2, 0, _i = _ref2.length - 1) : (_i = 0, []), last = _ref2[_i++];
     return _.extend(last, {
@@ -326,4 +334,4 @@ _pipeline: function() {
   return _(fs.readdirSync(dir)).map(function(filename) {
-    var name, _ref1;
-    name = (_ref1 = filename.match(/^([^\.]\S+)\.js$/)) != null ? _ref1[1] : void 0;
+    var name, _ref2;
+    name = (_ref2 = filename.match(/^([^\.]\S+)\.js$/)) != null ? _ref2[1] : void 0;
     if (!name) {
@@ -330,0 +338,0 @@ return;

package.json

 {
   "name": "understream",
-  "version": "0.10.14",
+  "version": "0.11.0",
   "description": "stream helpers",
   "engines": {
-    "node": ">=0.10.x"
+    "node": ">=10.x"
   },
@@ -26,8 +26,8 @@ "main": "index.js",
   "devDependencies": {
+    "JSONStream": "~0.7.1",
     "coffee-script": "~1.6.2",
+    "mocha": "~1.9.0",
+    "mongoose": "^5.7.4",
     "sinon": "~1.5.2",
-    "mocha": "~1.9.0",
-    "through": "~2.3.4",
-    "mongoose": "~3.6.19",
-    "JSONStream": "~0.7.1"
+    "through": "~2.3.4"
   },
@@ -34,0 +34,0 @@ "publishConfig": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

136409

increased by0.8%

Lines of code

1283

increased by0.79%

Worsened metrics

Number of package files

87

decreased by-1.14%

Number of medium supply chain risk alerts

2

increased by100%

No dependency changes