Fixing tap for Issue #651

Author: mattpodwysocki

dist/rx.all.compat.js

@@ -2998,10 +2998,10 @@
    */
   var observableReturn = Observable['return'] = Observable.just = Observable.returnValue = function (value, scheduler) {
     isScheduler(scheduler) || (scheduler = immediateScheduler);
-    return new AnonymousObservable(function (observer) {
-      return scheduler.scheduleWithState(value, function (_, v) {
-        observer.onNext(v);
-        observer.onCompleted();
+    return new AnonymousObservable(function (o) {
+      return scheduler.scheduleWithState(value, function(_,v) {
+        o.onNext(v);
+        o.onCompleted();
       });
     });
   };

dist/rx.all.compat.map

@@ -2853,10 +2853,10 @@
    */
   var observableReturn = Observable['return'] = Observable.just = Observable.returnValue = function (value, scheduler) {
     isScheduler(scheduler) || (scheduler = immediateScheduler);
-    return new AnonymousObservable(function (observer) {
-      return scheduler.scheduleWithState(value, function (_, v) {
-        observer.onNext(v);
-        observer.onCompleted();
+    return new AnonymousObservable(function (o) {
+      return scheduler.scheduleWithState(value, function(_,v) {
+        o.onNext(v);
+        o.onCompleted();
       });
     });
   };

dist/rx.all.js

@@ -2998,10 +2998,10 @@
    */
   var observableReturn = Observable['return'] = Observable.just = Observable.returnValue = function (value, scheduler) {
     isScheduler(scheduler) || (scheduler = immediateScheduler);
-    return new AnonymousObservable(function (observer) {
-      return scheduler.scheduleWithState(value, function (_, v) {
-        observer.onNext(v);
-        observer.onCompleted();
+    return new AnonymousObservable(function (o) {
+      return scheduler.scheduleWithState(value, function(_,v) {
+        o.onNext(v);
+        o.onCompleted();
       });
     });
   };

dist/rx.all.map

@@ -2807,10 +2807,10 @@
    */
   var observableReturn = Observable['return'] = Observable.just = Observable.returnValue = function (value, scheduler) {
     isScheduler(scheduler) || (scheduler = immediateScheduler);
-    return new AnonymousObservable(function (observer) {
-      return scheduler.scheduleWithState(value, function (_, v) {
-        observer.onNext(v);
-        observer.onCompleted();
+    return new AnonymousObservable(function (o) {
+      return scheduler.scheduleWithState(value, function(_,v) {
+        o.onNext(v);
+        o.onCompleted();
       });
     });
   };

dist/rx.compat.js

@@ -2647,10 +2647,10 @@
    */
   var observableReturn = Observable['return'] = Observable.just = Observable.returnValue = function (value, scheduler) {
     isScheduler(scheduler) || (scheduler = immediateScheduler);
-    return new AnonymousObservable(function (observer) {
-      return scheduler.scheduleWithState(value, function (_, v) {
-        observer.onNext(v);
-        observer.onCompleted();
+    return new AnonymousObservable(function (o) {
+      return scheduler.scheduleWithState(value, function(_,v) {
+        o.onNext(v);
+        o.onCompleted();
       });
     });
   };

dist/rx.compat.map

@@ -2458,10 +2458,10 @@
    */
   var observableReturn = Observable['return'] = Observable.just = Observable.returnValue = function (value, scheduler) {
     isScheduler(scheduler) || (scheduler = immediateScheduler);
-    return new AnonymousObservable(function (observer) {
-      return scheduler.scheduleWithState(value, function (_, v) {
-        observer.onNext(v);
-        observer.onCompleted();
+    return new AnonymousObservable(function (o) {
+      return scheduler.scheduleWithState(value, function(_,v) {
+        o.onNext(v);
+        o.onCompleted();
       });
     });
   };