Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
AnimationFrame.ts	1.42 KB	-rw-rw-r--	2022-08-30 11:49
ArgumentOutOfRangeError.ts	530 B	-rw-rw-r--	2022-08-30 11:49
EmptyError.ts	433 B	-rw-rw-r--	2022-08-30 11:49
FastMap.ts	596 B	-rw-rw-r--	2022-08-30 11:49
Immediate.ts	7.36 KB	-rw-rw-r--	2022-08-30 11:49
Map.ts	130 B	-rw-rw-r--	2022-08-30 11:49
MapPolyfill.ts	917 B	-rw-rw-r--	2022-08-30 11:49
ObjectUnsubscribedError.ts	460 B	-rw-rw-r--	2022-08-30 11:49
Set.ts	820 B	-rw-rw-r--	2022-08-30 11:49
TimeoutError.ts	362 B	-rw-rw-r--	2022-08-30 11:49
UnsubscriptionError.ts	550 B	-rw-rw-r--	2022-08-30 11:49
applyMixins.ts	406 B	-rw-rw-r--	2022-08-30 11:49
assign.ts	453 B	-rw-rw-r--	2022-08-30 11:49
errorObject.ts	133 B	-rw-rw-r--	2022-08-30 11:49
identity.ts	53 B	-rw-rw-r--	2022-08-30 11:49
isArray.ts	102 B	-rw-rw-r--	2022-08-30 11:49
isArrayLike.ts	97 B	-rw-rw-r--	2022-08-30 11:49
isDate.ts	104 B	-rw-rw-r--	2022-08-30 11:49
isFunction.ts	88 B	-rw-rw-r--	2022-08-30 11:49
isNumeric.ts	425 B	-rw-rw-r--	2022-08-30 11:49
isObject.ts	95 B	-rw-rw-r--	2022-08-30 11:49
isPromise.ts	188 B	-rw-rw-r--	2022-08-30 11:49
isScheduler.ts	169 B	-rw-rw-r--	2022-08-30 11:49
noop.ts	57 B	-rw-rw-r--	2022-08-30 11:49
not.ts	259 B	-rw-rw-r--	2022-08-30 11:49
pipe.ts	2.33 KB	-rw-rw-r--	2022-08-30 11:49
root.ts	1.09 KB	-rw-rw-r--	2022-08-30 11:49
subscribeToResult.ts	3.11 KB	-rw-rw-r--	2022-08-30 11:49
toSubscriber.ts	752 B	-rw-rw-r--	2022-08-30 11:49
tryCatch.ts	352 B	-rw-rw-r--	2022-08-30 11:49

Rename

import { root } from './root';
import { isArrayLike } from './isArrayLike';
import { isPromise } from './isPromise';
import { isObject } from './isObject';
import { Subscriber } from '../Subscriber';
import { Observable, ObservableInput } from '../Observable';
import { iterator as Symbol_iterator } from '../symbol/iterator';
import { Subscription } from '../Subscription';
import { InnerSubscriber } from '../InnerSubscriber';
import { OuterSubscriber } from '../OuterSubscriber';
import { observable as Symbol_observable } from '../symbol/observable';

export function subscribeToResult<T, R>(outerSubscriber: OuterSubscriber<T, R>,
                                        result: any,
                                        outerValue?: T,
                                        outerIndex?: number): Subscription;
export function subscribeToResult<T>(outerSubscriber: OuterSubscriber<any, any>,
                                     result: ObservableInput<T>,
                                     outerValue?: T,
                                     outerIndex?: number): Subscription {
  let destination: Subscriber<any> = new InnerSubscriber(outerSubscriber, outerValue, outerIndex);

if (destination.closed) {
    return null;
  }

if (result instanceof Observable) {
    if (result._isScalar) {
      destination.next((<any>result).value);
      destination.complete();
      return null;
    } else {
      destination.syncErrorThrowable = true;
      return result.subscribe(destination);
    }
  } else if (isArrayLike(result)) {
    for (let i = 0, len = result.length; i < len && !destination.closed; i++) {
      destination.next(result[i]);
    }
    if (!destination.closed) {
      destination.complete();
    }
  } else if (isPromise(result)) {
    result.then(
      (value) => {
        if (!destination.closed) {
          destination.next(<any>value);
          destination.complete();
        }
      },
      (err: any) => destination.error(err)
    )
    .then(null, (err: any) => {
      // Escaping the Promise trap: globally throw unhandled errors
      root.setTimeout(() => { throw err; });
    });
    return destination;
  } else if (result && typeof result[Symbol_iterator] === 'function') {
    const iterator = <any>result[Symbol_iterator]();
    do {
      let item = iterator.next();
      if (item.done) {
        destination.complete();
        break;
      }
      destination.next(item.value);
      if (destination.closed) {
        break;
      }
    } while (true);
  } else if (result && typeof result[Symbol_observable] === 'function') {
    const obs = result[Symbol_observable]();
    if (typeof obs.subscribe !== 'function') {
      destination.error(new TypeError('Provided object does not correctly implement Symbol.observable'));
    } else {
      return obs.subscribe(new InnerSubscriber(outerSubscriber, outerValue, outerIndex));
    }
  } else {
    const value = isObject(result) ? 'an invalid object' : `'${result}'`;
    const msg = `You provided ${value} where a stream was expected.`
      + ' You can provide an Observable, Promise, Array, or Iterable.';
    destination.error(new TypeError(msg));
  }
  return null;
}