fix(async): improve Rx support in ObservableWrapper

2015-12-04 15:33:41 -08:00 · 2015-12-04 15:33:41 -08:00 · 4a17e6906c
parent 8d3e5596dc
commit 4a17e6906c
1 changed files with 1 additions and 1 deletions
--- 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.