Fixing fromCallback bug for Issue #417

Author: mattpodwysocki

dist/rx.all.compat.js

@@ -5437,12 +5437,12 @@ if (!Array.prototype.forEach) {
       var args = slice.call(arguments, 0);
 
       return new AnonymousObservable(function (observer) {
-        function handler(e) {
-          var results = e;
+        function handler() {
+          var results = arguments;
 
           if (selector) {
             try {
-              results = selector(arguments);
+              results = selector(results);
             } catch (err) {
               observer.onError(err);
               return;
@@ -9399,7 +9399,7 @@ if (!Array.prototype.forEach) {
     };
 
     AutoDetachObserverPrototype.setDisposable = function (value) { this.m.setDisposable(value); };
-    AutoDetachObserverPrototype.getDisposable = function (value) { return this.m.getDisposable(); };
+    AutoDetachObserverPrototype.getDisposable = function () { return this.m.getDisposable(); };
 
     AutoDetachObserverPrototype.dispose = function () {
       __super__.prototype.dispose.call(this);

dist/rx.all.compat.map

@@ -5286,12 +5286,12 @@
       var args = slice.call(arguments, 0);
 
       return new AnonymousObservable(function (observer) {
-        function handler(e) {
-          var results = e;
+        function handler() {
+          var results = arguments;
 
           if (selector) {
             try {
-              results = selector(arguments);
+              results = selector(results);
             } catch (err) {
               observer.onError(err);
               return;
@@ -9180,7 +9180,7 @@
     };
 
     AutoDetachObserverPrototype.setDisposable = function (value) { this.m.setDisposable(value); };
-    AutoDetachObserverPrototype.getDisposable = function (value) { return this.m.getDisposable(); };
+    AutoDetachObserverPrototype.getDisposable = function () { return this.m.getDisposable(); };
 
     AutoDetachObserverPrototype.dispose = function () {
       __super__.prototype.dispose.call(this);

dist/rx.all.compat.min.js

@@ -346,12 +346,12 @@
       var args = slice.call(arguments, 0);
 
       return new AnonymousObservable(function (observer) {
-        function handler(e) {
-          var results = e;
+        function handler() {
+          var results = arguments;
 
           if (selector) {
             try {
-              results = selector(arguments);
+              results = selector(results);
             } catch (err) {
               observer.onError(err);
               return;

dist/rx.all.js

@@ -346,12 +346,12 @@
       var args = slice.call(arguments, 0);
 
       return new AnonymousObservable(function (observer) {
-        function handler(e) {
-          var results = e;
+        function handler() {
+          var results = arguments;
 
           if (selector) {
             try {
-              results = selector(arguments);
+              results = selector(results);
             } catch (err) {
               observer.onError(err);
               return;