stream-transform - npm Package Compare versions

Comparing version 0.1.1 to 0.1.2

lib/index.js

@@ -47,5 +47,5 @@ // Generated by CoffeeScript 1.9.2
     process.nextTick(function() {
-      var l, len1, row;
-      for (l = 0, len1 = data.length; l < len1; l++) {
-        row = data[l];
+      var len1, m, row;
+      for (m = 0, len1 = data.length; m < len1; m++) {
+        row = data[m];
         if (error) {
@@ -65,3 +65,7 @@ break;
       while ((r = transform.read())) {
-        results.push(result.push(r));
+        if (callback) {
+          results.push(result.push(r));
+        } else {
+          results.push(void 0);
+        }
       }
@@ -105,3 +109,3 @@ return results;
 Transformer.prototype._transform = function(chunk, encoding, cb) {
-  var err;
+  var callback, err, l;
   this.started++;
@@ -114,4 +118,10 @@ this.running++;
   try {
-    if (this.transform.length === 2) {
-      this.transform.call(null, chunk, (function(_this) {
+    l = this.transform.length;
+    if (this.options.params != null) {
+      l--;
+    }
+    if (l === 1) {
+      this._done(null, [this.transform.call(null, chunk, this.options.params)], cb);
+    } else if (l === 2) {
+      callback = (function(_this) {
         return function() {
@@ -122,5 +132,6 @@ var chunks, err;
         };
-      })(this));
+      })(this);
+      this.transform.call(null, chunk, callback, this.options.params);
     } else {
-      this._done(null, [this.transform.call(null, chunk)], cb);
+      throw Error("Invalid handler arguments");
     }
@@ -127,0 +138,0 @@ return false;

package.json

 {
-  "version": "0.1.1",
+  "version": "0.1.2",
   "name": "stream-transform",
@@ -4,0 +4,0 @@ "description": "Object transformations implementing the Node.js `stream.Transform` API",

No alert changes

Improved metrics

Total package byte prevSize

10207

increased by3.11%

Lines of code

220

increased by5.26%

No dependency changes