Perf improvements for Issue #519

Author: mattpodwysocki

dist/rx.all.compat.js

@@ -6067,8 +6067,8 @@
           if (selector) {
             try {
               results = selector(results);
-            } catch (err) {
-              return observer.onError(err);
+            } catch (e) {
+              return observer.onError(e);
             }
 
             observer.onNext(results);
@@ -6098,7 +6098,8 @@
    */
   Observable.fromNodeCallback = function (func, context, selector) {
     return function () {
-      for(var args = [], i = 0, len = arguments.length; i < len; i++) { args.push(arguments[i]); }
+      var len = arguments.length, args = new Array(len);
+      for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
 
       return new AnonymousObservable(function (observer) {
         function handler(err) {
@@ -6107,7 +6108,8 @@
             return;
           }
 
-          for(var results = [], i = 1, len = arguments.length; i < len; i++) { results.push(arguments[i]); }
+          var len = arguments.length, results = new Array(len - 1);
+          for(var i = 1; i < len; i++) { results[i - 1] = arguments[i]; }
 
           if (selector) {
             try {

dist/rx.all.compat.map

@@ -5922,8 +5922,8 @@
           if (selector) {
             try {
               results = selector(results);
-            } catch (err) {
-              return observer.onError(err);
+            } catch (e) {
+              return observer.onError(e);
             }
 
             observer.onNext(results);
@@ -5953,7 +5953,8 @@
    */
   Observable.fromNodeCallback = function (func, context, selector) {
     return function () {
-      for(var args = [], i = 0, len = arguments.length; i < len; i++) { args.push(arguments[i]); }
+      var len = arguments.length, args = new Array(len);
+      for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
 
       return new AnonymousObservable(function (observer) {
         function handler(err) {
@@ -5962,7 +5963,8 @@
             return;
           }
 
-          for(var results = [], i = 1, len = arguments.length; i < len; i++) { results.push(arguments[i]); }
+          var len = arguments.length, results = new Array(len - 1);
+          for(var i = 1; i < len; i++) { results[i - 1] = arguments[i]; }
 
           if (selector) {
             try {

dist/rx.all.compat.min.js

@@ -309,8 +309,8 @@
           if (selector) {
             try {
               results = selector(results);
-            } catch (err) {
-              return observer.onError(err);
+            } catch (e) {
+              return observer.onError(e);
             }
 
             observer.onNext(results);
@@ -340,7 +340,8 @@
    */
   Observable.fromNodeCallback = function (func, context, selector) {
     return function () {
-      for(var args = [], i = 0, len = arguments.length; i < len; i++) { args.push(arguments[i]); }
+      var len = arguments.length, args = new Array(len);
+      for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
 
       return new AnonymousObservable(function (observer) {
         function handler(err) {
@@ -349,7 +350,8 @@
             return;
           }
 
-          for(var results = [], i = 1, len = arguments.length; i < len; i++) { results.push(arguments[i]); }
+          var len = arguments.length, results = new Array(len - 1);
+          for(var i = 1; i < len; i++) { results[i - 1] = arguments[i]; }
 
           if (selector) {
             try {

dist/rx.all.js

@@ -309,8 +309,8 @@
           if (selector) {
             try {
               results = selector(results);
-            } catch (err) {
-              return observer.onError(err);
+            } catch (e) {
+              return observer.onError(e);
             }
 
             observer.onNext(results);
@@ -340,7 +340,8 @@
    */
   Observable.fromNodeCallback = function (func, context, selector) {
     return function () {
-      for(var args = [], i = 0, len = arguments.length; i < len; i++) { args.push(arguments[i]); }
+      var len = arguments.length, args = new Array(len);
+      for(var i = 0; i < len; i++) { args[i] = arguments[i]; }
 
       return new AnonymousObservable(function (observer) {
         function handler(err) {
@@ -349,7 +350,8 @@
             return;
           }
 
-          for(var results = [], i = 1, len = arguments.length; i < len; i++) { results.push(arguments[i]); }
+          var len = arguments.length, results = new Array(len - 1);
+          for(var i = 1; i < len; i++) { results[i - 1] = arguments[i]; }
 
           if (selector) {
             try {