fix(core): make .toRx() return Subject

robwormald · robwormald · commit 4a36fd82030d · 2015-10-06T23:27:35.000Z
this was broken in the original great RxNext migration. fixes angular#4521 Closes angular#4540
diff --git a/modules/angular2/src/core/facade/async.ts b/modules/angular2/src/core/facade/async.ts
@@ -137,7 +137,7 @@ export class EventEmitter extends Observable {
                                    () => generator.return ? generator.return () : null);
   }
 
-  toRx(): any { return this; }
+  toRx(): any { return this._subject; }
 
   next(value: any) { this._subject.next(value); }
 

Original file line number	Diff line number	Diff line change
`@@ -137,7 +137,7 @@ export class EventEmitter extends Observable {`
`137`	`137`	`() => generator.return ? generator.return () : null);`
`138`	`138`	`}`
`139`	`139`
`140`		`- toRx(): any { return this; }`
	`140`	`+ toRx(): any { return this._subject; }`
`141`	`141`
`142`	`142`	`next(value: any) { this._subject.next(value); }`
`143`	`143`