fix(async): improve Rx support in ObservableWrapper

robwormald · vsavkin · commit 4a17e6906c0c · 2015-12-10T21:49:40.000Z
diff --git a/modules/angular2/src/facade/async.ts b/modules/angular2/src/facade/async.ts
@@ -39,7 +39,7 @@ export class ObservableWrapper {
     return emitter.subscribe({next: onNext, error: onError, complete: onComplete});
   }
 
-  static isObservable(obs: any): boolean { return obs instanceof RxObservable; }
+  static isObservable(obs: any): boolean { return !!obs.subscribe; }
 
   /**
    * Returns whether `obs` has any subscribers listening to events.

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ export class ObservableWrapper {`
`39`	`39`	`return emitter.subscribe({next: onNext, error: onError, complete: onComplete});`
`40`	`40`	`}`
`41`	`41`
`42`		`- static isObservable(obs: any): boolean { return obs instanceof RxObservable; }`
	`42`	`+ static isObservable(obs: any): boolean { return !!obs.subscribe; }`
`43`	`43`
`44`	`44`	`/**`
`45`	`45`	* Returns whether `obs` has any subscribers listening to events.