5e05c24c8975cbe0ae8a447a1fcfb1a94901ef0868f1686fe04b03f55c8e253960f0b8133523a8f93e51941c07ad857c72db7bb4b829472483b528c0471366 503 B

12345678910111213
  1. /** prettier */
  2. import { Observable } from '../Observable';
  3. import { isFunction } from './isFunction';
  4. /**
  5. * Tests to see if the object is an RxJS {@link Observable}
  6. * @param obj the object to test
  7. */
  8. export function isObservable(obj: any): obj is Observable<unknown> {
  9. // The !! is to ensure that this publicly exposed function returns
  10. // `false` if something like `null` or `0` is passed.
  11. return !!obj && (obj instanceof Observable || (isFunction(obj.lift) && isFunction(obj.subscribe)));
  12. }