subscribeToResult.js 721 B

1234567891011121314151617
  1. /** PURE_IMPORTS_START _InnerSubscriber,_subscribeTo,_Observable PURE_IMPORTS_END */
  2. import { InnerSubscriber } from '../InnerSubscriber';
  3. import { subscribeTo } from './subscribeTo';
  4. import { Observable } from '../Observable';
  5. export function subscribeToResult(outerSubscriber, result, outerValue, outerIndex, innerSubscriber) {
  6. if (innerSubscriber === void 0) {
  7. innerSubscriber = new InnerSubscriber(outerSubscriber, outerValue, outerIndex);
  8. }
  9. if (innerSubscriber.closed) {
  10. return undefined;
  11. }
  12. if (result instanceof Observable) {
  13. return result.subscribe(innerSubscriber);
  14. }
  15. return subscribeTo(result)(innerSubscriber);
  16. }
  17. //# sourceMappingURL=subscribeToResult.js.map