added .angular to gitignore and fixed unit test
This commit is contained in:
Konstantin Schütte
parent
a1f680af04
commit
0a38b8dfd4
273 changed files with 271 additions and 547 deletions
Binary file not shown.
Binary file not shown.
Binary file not shown.
Binary file not shown.
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"export const COMPLETE_NOTIFICATION = (() => createNotification('C', undefined, undefined))();\nexport function errorNotification(error) {\n return createNotification('E', undefined, error);\n}\nexport function nextNotification(value) {\n return createNotification('N', value, undefined);\n}\nexport function createNotification(kind, value, error) {\n return {\n kind,\n value,\n error\n };\n} //# sourceMappingURL=NotificationFactories.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function every(predicate, thisArg) {\n return operate((source, subscriber) => {\n let index = 0;\n source.subscribe(new OperatorSubscriber(subscriber, value => {\n if (!predicate.call(thisArg, value, index++, source)) {\n subscriber.next(false);\n subscriber.complete();\n }\n }, () => {\n subscriber.next(true);\n subscriber.complete();\n }));\n });\n} //# sourceMappingURL=every.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { noop } from '../util/noop';\nexport const NEVER = new Observable(noop);\nexport function never() {\n return NEVER;\n} //# sourceMappingURL=never.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { identity } from '../util/identity';\nimport { mapOneOrManyArgs } from '../util/mapOneOrManyArgs';\nimport { pipe } from '../util/pipe';\nimport { mergeMap } from './mergeMap';\nimport { toArray } from './toArray';\nexport function joinAllInternals(joinFn, project) {\n return pipe(toArray(), mergeMap(sources => joinFn(sources)), project ? mapOneOrManyArgs(project) : identity);\n} //# sourceMappingURL=joinAllInternals.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { AsyncAction } from './AsyncAction';\nimport { Subscription } from '../Subscription';\nimport { AsyncScheduler } from './AsyncScheduler';\nexport let VirtualTimeScheduler = /*#__PURE__*/(() => {\n class VirtualTimeScheduler extends AsyncScheduler {\n constructor(schedulerActionCtor = VirtualAction, maxFrames = Infinity) {\n super(schedulerActionCtor, () => this.frame);\n this.maxFrames = maxFrames;\n this.frame = 0;\n this.index = -1;\n }\n\n flush() {\n const {\n actions,\n maxFrames\n } = this;\n let error;\n let action;\n\n while ((action = actions[0]) && action.delay <= maxFrames) {\n actions.shift();\n this.frame = action.delay;\n\n if (error = action.execute(action.state, action.delay)) {\n break;\n }\n }\n\n if (error) {\n while (action = actions.shift()) {\n action.unsubscribe();\n }\n\n throw error;\n }\n }\n\n }\n\n VirtualTimeScheduler.frameTimeFactor = 10;\n return VirtualTimeScheduler;\n})();\nexport class VirtualAction extends AsyncAction {\n constructor(scheduler, work, index = scheduler.index += 1) {\n super(scheduler, work);\n this.scheduler = scheduler;\n this.work = work;\n this.index = index;\n this.active = true;\n this.index = scheduler.index = index;\n }\n\n schedule(state, delay = 0) {\n if (Number.isFinite(delay)) {\n if (!this.id) {\n return super.schedule(state, delay);\n }\n\n this.active = false;\n const action = new VirtualAction(this.scheduler, this.work);\n this.add(action);\n return action.schedule(state, delay);\n } else {\n return Subscription.EMPTY;\n }\n }\n\n requestAsyncId(scheduler, id, delay = 0) {\n this.delay = scheduler.frame + delay;\n const {\n actions\n } = scheduler;\n actions.push(this);\n actions.sort(VirtualAction.sortActions);\n return true;\n }\n\n recycleAsyncId(scheduler, id, delay = 0) {\n return undefined;\n }\n\n _execute(state, delay) {\n if (this.active === true) {\n return super._execute(state, delay);\n }\n }\n\n static sortActions(a, b) {\n if (a.delay === b.delay) {\n if (a.index === b.index) {\n return 0;\n } else if (a.index > b.index) {\n return 1;\n } else {\n return -1;\n }\n } else if (a.delay > b.delay) {\n return 1;\n } else {\n return -1;\n }\n }\n\n} //# sourceMappingURL=VirtualTimeScheduler.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { createErrorClass } from './createErrorClass';\nexport const ArgumentOutOfRangeError = createErrorClass(_super => function ArgumentOutOfRangeErrorImpl() {\n _super(this);\n\n this.name = 'ArgumentOutOfRangeError';\n this.message = 'argument out of range';\n}); //# sourceMappingURL=ArgumentOutOfRangeError.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { createErrorClass } from './createErrorClass';\nexport const SequenceError = createErrorClass(_super => function SequenceErrorImpl(message) {\n _super(this);\n\n this.name = 'SequenceError';\n this.message = message;\n}); //# sourceMappingURL=SequenceError.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { SafeSubscriber, Subscriber } from './Subscriber';\nimport { isSubscription } from './Subscription';\nimport { observable as Symbol_observable } from './symbol/observable';\nimport { pipeFromArray } from './util/pipe';\nimport { config } from './config';\nimport { isFunction } from './util/isFunction';\nimport { errorContext } from './util/errorContext';\nexport let Observable = /*#__PURE__*/(() => {\n class Observable {\n constructor(subscribe) {\n if (subscribe) {\n this._subscribe = subscribe;\n }\n }\n\n lift(operator) {\n const observable = new Observable();\n observable.source = this;\n observable.operator = operator;\n return observable;\n }\n\n subscribe(observerOrNext, error, complete) {\n const subscriber = isSubscriber(observerOrNext) ? observerOrNext : new SafeSubscriber(observerOrNext, error, complete);\n errorContext(() => {\n const {\n operator,\n source\n } = this;\n subscriber.add(operator ? operator.call(subscriber, source) : source ? this._subscribe(subscriber) : this._trySubscribe(subscriber));\n });\n return subscriber;\n }\n\n _trySubscribe(sink) {\n try {\n return this._subscribe(sink);\n } catch (err) {\n sink.error(err);\n }\n }\n\n forEach(next, promiseCtor) {\n promiseCtor = getPromiseCtor(promiseCtor);\n return new promiseCtor((resolve, reject) => {\n const subscriber = new SafeSubscriber({\n next: value => {\n try {\n next(value);\n } catch (err) {\n reject(err);\n subscriber.unsubscribe();\n }\n },\n error: reject,\n complete: resolve\n });\n this.subscribe(subscriber);\n });\n }\n\n _subscribe(subscriber) {\n var _a;\n\n return (_a = this.source) === null || _a === void 0 ? void 0 : _a.subscribe(subscriber);\n }\n\n [Symbol_observable]() {\n return this;\n }\n\n pipe(...operations) {\n return pipeFromArray(operations)(this);\n }\n\n toPromise(promiseCtor) {\n promiseCtor = getPromiseCtor(promiseCtor);\n return new promiseCtor((resolve, reject) => {\n let value;\n this.subscribe(x => value = x, err => reject(err), () => resolve(value));\n });\n }\n\n }\n\n Observable.create = subscribe => {\n return new Observable(subscribe);\n };\n\n return Observable;\n})();\n\nfunction getPromiseCtor(promiseCtor) {\n var _a;\n\n return (_a = promiseCtor !== null && promiseCtor !== void 0 ? promiseCtor : config.Promise) !== null && _a !== void 0 ? _a : Promise;\n}\n\nfunction isObserver(value) {\n return value && isFunction(value.next) && isFunction(value.error) && isFunction(value.complete);\n}\n\nfunction isSubscriber(value) {\n return value && value instanceof Subscriber || isObserver(value) && isSubscription(value);\n} //# sourceMappingURL=Observable.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"export const config = {\n onUnhandledError: null,\n onStoppedNotification: null,\n Promise: undefined,\n useDeprecatedSynchronousErrorHandling: false,\n useDeprecatedNextContext: false\n}; //# sourceMappingURL=config.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { identity } from '../util/identity';\nimport { isScheduler } from '../util/isScheduler';\nimport { defer } from './defer';\nimport { scheduleIterable } from '../scheduled/scheduleIterable';\nexport function generate(initialStateOrOptions, condition, iterate, resultSelectorOrScheduler, scheduler) {\n let resultSelector;\n let initialState;\n\n if (arguments.length === 1) {\n ({\n initialState,\n condition,\n iterate,\n resultSelector = identity,\n scheduler\n } = initialStateOrOptions);\n } else {\n initialState = initialStateOrOptions;\n\n if (!resultSelectorOrScheduler || isScheduler(resultSelectorOrScheduler)) {\n resultSelector = identity;\n scheduler = resultSelectorOrScheduler;\n } else {\n resultSelector = resultSelectorOrScheduler;\n }\n }\n\n function* gen() {\n for (let state = initialState; !condition || condition(state); state = iterate(state)) {\n yield resultSelector(state);\n }\n }\n\n return defer(scheduler ? () => scheduleIterable(gen(), scheduler) : gen);\n} //# sourceMappingURL=generate.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { BehaviorSubject } from '../BehaviorSubject';\nimport { ConnectableObservable } from '../observable/ConnectableObservable';\nexport function publishBehavior(initialValue) {\n return source => {\n const subject = new BehaviorSubject(initialValue);\n return new ConnectableObservable(source, () => subject);\n };\n} //# sourceMappingURL=publishBehavior.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { from } from '../observable/from';\nimport { take } from '../operators/take';\nimport { Subject } from '../Subject';\nimport { SafeSubscriber } from '../Subscriber';\nimport { operate } from '../util/lift';\nexport function share(options = {}) {\n const {\n connector = () => new Subject(),\n resetOnError = true,\n resetOnComplete = true,\n resetOnRefCountZero = true\n } = options;\n return wrapperSource => {\n let connection = null;\n let resetConnection = null;\n let subject = null;\n let refCount = 0;\n let hasCompleted = false;\n let hasErrored = false;\n\n const cancelReset = () => {\n resetConnection === null || resetConnection === void 0 ? void 0 : resetConnection.unsubscribe();\n resetConnection = null;\n };\n\n const reset = () => {\n cancelReset();\n connection = subject = null;\n hasCompleted = hasErrored = false;\n };\n\n const resetAndUnsubscribe = () => {\n const conn = connection;\n reset();\n conn === null || conn === void 0 ? void 0 : conn.unsubscribe();\n };\n\n return operate((source, subscriber) => {\n refCount++;\n\n if (!hasErrored && !hasCompleted) {\n cancelReset();\n }\n\n const dest = subject = subject !== null && subject !== void 0 ? subject : connector();\n subscriber.add(() => {\n refCount--;\n\n if (refCount === 0 && !hasErrored && !hasCompleted) {\n resetConnection = handleReset(resetAndUnsubscribe, resetOnRefCountZero);\n }\n });\n dest.subscribe(subscriber);\n\n if (!connection) {\n connection = new SafeSubscriber({\n next: value => dest.next(value),\n error: err => {\n hasErrored = true;\n cancelReset();\n resetConnection = handleReset(reset, resetOnError, err);\n dest.error(err);\n },\n complete: () => {\n hasCompleted = true;\n cancelReset();\n resetConnection = handleReset(reset, resetOnComplete);\n dest.complete();\n }\n });\n from(source).subscribe(connection);\n }\n })(wrapperSource);\n };\n}\n\nfunction handleReset(reset, on, ...args) {\n if (on === true) {\n reset();\n return null;\n }\n\n if (on === false) {\n return null;\n }\n\n return on(...args).pipe(take(1)).subscribe(() => reset());\n} //# sourceMappingURL=share.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { operate } from '../util/lift';\nexport function subscribeOn(scheduler, delay = 0) {\n return operate((source, subscriber) => {\n subscriber.add(scheduler.schedule(() => source.subscribe(subscriber), delay));\n });\n} //# sourceMappingURL=subscribeOn.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { EmptyError } from '../util/EmptyError';\nimport { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function throwIfEmpty(errorFactory = defaultErrorFactory) {\n return operate((source, subscriber) => {\n let hasValue = false;\n source.subscribe(new OperatorSubscriber(subscriber, value => {\n hasValue = true;\n subscriber.next(value);\n }, () => hasValue ? subscriber.complete() : subscriber.error(errorFactory())));\n });\n}\n\nfunction defaultErrorFactory() {\n return new EmptyError();\n} //# sourceMappingURL=throwIfEmpty.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nexport function scheduleArray(input, scheduler) {\n return new Observable(subscriber => {\n let i = 0;\n return scheduler.schedule(function () {\n if (i === input.length) {\n subscriber.complete();\n } else {\n subscriber.next(input[i++]);\n\n if (!subscriber.closed) {\n this.schedule();\n }\n }\n });\n });\n} //# sourceMappingURL=scheduleArray.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { iterator as Symbol_iterator } from '../symbol/iterator';\nimport { isFunction } from '../util/isFunction';\nimport { executeSchedule } from '../util/executeSchedule';\nexport function scheduleIterable(input, scheduler) {\n return new Observable(subscriber => {\n let iterator;\n executeSchedule(subscriber, scheduler, () => {\n iterator = input[Symbol_iterator]();\n executeSchedule(subscriber, scheduler, () => {\n let value;\n let done;\n\n try {\n ({\n value,\n done\n } = iterator.next());\n } catch (err) {\n subscriber.error(err);\n return;\n }\n\n if (done) {\n subscriber.complete();\n } else {\n subscriber.next(value);\n }\n }, 0, true);\n });\n return () => isFunction(iterator === null || iterator === void 0 ? void 0 : iterator.return) && iterator.return();\n });\n} //# sourceMappingURL=scheduleIterable.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Immediate } from '../util/Immediate';\nconst {\n setImmediate,\n clearImmediate\n} = Immediate;\nexport const immediateProvider = {\n setImmediate(...args) {\n const {\n delegate\n } = immediateProvider;\n return ((delegate === null || delegate === void 0 ? void 0 : delegate.setImmediate) || setImmediate)(...args);\n },\n\n clearImmediate(handle) {\n const {\n delegate\n } = immediateProvider;\n return ((delegate === null || delegate === void 0 ? void 0 : delegate.clearImmediate) || clearImmediate)(handle);\n },\n\n delegate: undefined\n}; //# sourceMappingURL=immediateProvider.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { AsapAction } from './AsapAction';\nimport { AsapScheduler } from './AsapScheduler';\nexport const asapScheduler = new AsapScheduler(AsapAction);\nexport const asap = asapScheduler; //# sourceMappingURL=asap.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { switchMap } from './switchMap';\nimport { operate } from '../util/lift';\nexport function switchScan(accumulator, seed) {\n return operate((source, subscriber) => {\n let state = seed;\n switchMap((value, index) => accumulator(state, value, index), (_, innerValue) => (state = innerValue, innerValue))(source).subscribe(subscriber);\n return () => {\n state = null;\n };\n });\n} //# sourceMappingURL=switchScan.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import * as __NgCli_bootstrap_1 from \"@angular/platform-browser\";\nimport { enableProdMode } from '@angular/core';\nimport { AppModule } from './app/app.module';\nimport { environment } from './environments/environment';\n\nif (environment.production) {\n enableProdMode();\n}\n\n__NgCli_bootstrap_1.platformBrowser().bootstrapModule(AppModule).catch(err => console.error(err));","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { reduce } from './reduce';\nimport { isFunction } from '../util/isFunction';\nexport function min(comparer) {\n return reduce(isFunction(comparer) ? (x, y) => comparer(x, y) < 0 ? x : y : (x, y) => x < y ? x : y);\n} //# sourceMappingURL=min.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function pairwise() {\n return operate((source, subscriber) => {\n let prev;\n let hasPrev = false;\n source.subscribe(new OperatorSubscriber(subscriber, value => {\n const p = prev;\n prev = value;\n hasPrev && subscriber.next([p, value]);\n hasPrev = true;\n }));\n });\n} //# sourceMappingURL=pairwise.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { dateTimestampProvider } from '../scheduler/dateTimestampProvider';\nimport { map } from './map';\nexport function timestamp(timestampProvider = dateTimestampProvider) {\n return map(value => ({\n value,\n timestamp: timestampProvider.now()\n }));\n} //# sourceMappingURL=timestamp.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { isFunction } from './util/isFunction';\nimport { isSubscription, Subscription } from './Subscription';\nimport { config } from './config';\nimport { reportUnhandledError } from './util/reportUnhandledError';\nimport { noop } from './util/noop';\nimport { nextNotification, errorNotification, COMPLETE_NOTIFICATION } from './NotificationFactories';\nimport { timeoutProvider } from './scheduler/timeoutProvider';\nimport { captureError } from './util/errorContext';\nexport class Subscriber extends Subscription {\n constructor(destination) {\n super();\n this.isStopped = false;\n\n if (destination) {\n this.destination = destination;\n\n if (isSubscription(destination)) {\n destination.add(this);\n }\n } else {\n this.destination = EMPTY_OBSERVER;\n }\n }\n\n static create(next, error, complete) {\n return new SafeSubscriber(next, error, complete);\n }\n\n next(value) {\n if (this.isStopped) {\n handleStoppedNotification(nextNotification(value), this);\n } else {\n this._next(value);\n }\n }\n\n error(err) {\n if (this.isStopped) {\n handleStoppedNotification(errorNotification(err), this);\n } else {\n this.isStopped = true;\n\n this._error(err);\n }\n }\n\n complete() {\n if (this.isStopped) {\n handleStoppedNotification(COMPLETE_NOTIFICATION, this);\n } else {\n this.isStopped = true;\n\n this._complete();\n }\n }\n\n unsubscribe() {\n if (!this.closed) {\n this.isStopped = true;\n super.unsubscribe();\n this.destination = null;\n }\n }\n\n _next(value) {\n this.destination.next(value);\n }\n\n _error(err) {\n try {\n this.destination.error(err);\n } finally {\n this.unsubscribe();\n }\n }\n\n _complete() {\n try {\n this.destination.complete();\n } finally {\n this.unsubscribe();\n }\n }\n\n}\nexport class SafeSubscriber extends Subscriber {\n constructor(observerOrNext, error, complete) {\n super();\n let next;\n\n if (isFunction(observerOrNext)) {\n next = observerOrNext;\n } else if (observerOrNext) {\n ({\n next,\n error,\n complete\n } = observerOrNext);\n let context;\n\n if (this && config.useDeprecatedNextContext) {\n context = Object.create(observerOrNext);\n\n context.unsubscribe = () => this.unsubscribe();\n } else {\n context = observerOrNext;\n }\n\n next = next === null || next === void 0 ? void 0 : next.bind(context);\n error = error === null || error === void 0 ? void 0 : error.bind(context);\n complete = complete === null || complete === void 0 ? void 0 : complete.bind(context);\n }\n\n this.destination = {\n next: next ? wrapForErrorHandling(next, this) : noop,\n error: wrapForErrorHandling(error !== null && error !== void 0 ? error : defaultErrorHandler, this),\n complete: complete ? wrapForErrorHandling(complete, this) : noop\n };\n }\n\n}\n\nfunction wrapForErrorHandling(handler, instance) {\n return (...args) => {\n try {\n handler(...args);\n } catch (err) {\n if (config.useDeprecatedSynchronousErrorHandling) {\n captureError(err);\n } else {\n reportUnhandledError(err);\n }\n }\n };\n}\n\nfunction defaultErrorHandler(err) {\n throw err;\n}\n\nfunction handleStoppedNotification(notification, subscriber) {\n const {\n onStoppedNotification\n } = config;\n onStoppedNotification && timeoutProvider.setTimeout(() => onStoppedNotification(notification, subscriber));\n}\n\nexport const EMPTY_OBSERVER = {\n closed: true,\n next: noop,\n error: defaultErrorHandler,\n complete: noop\n}; //# sourceMappingURL=Subscriber.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { innerFrom } from '../observable/innerFrom';\nimport { Observable } from '../Observable';\nimport { mergeMap } from '../operators/mergeMap';\nimport { isArrayLike } from '../util/isArrayLike';\nimport { isFunction } from '../util/isFunction';\nimport { mapOneOrManyArgs } from '../util/mapOneOrManyArgs';\nconst nodeEventEmitterMethods = ['addListener', 'removeListener'];\nconst eventTargetMethods = ['addEventListener', 'removeEventListener'];\nconst jqueryMethods = ['on', 'off'];\nexport function fromEvent(target, eventName, options, resultSelector) {\n if (isFunction(options)) {\n resultSelector = options;\n options = undefined;\n }\n\n if (resultSelector) {\n return fromEvent(target, eventName, options).pipe(mapOneOrManyArgs(resultSelector));\n }\n\n const [add, remove] = isEventTarget(target) ? eventTargetMethods.map(methodName => handler => target[methodName](eventName, handler, options)) : isNodeStyleEventEmitter(target) ? nodeEventEmitterMethods.map(toCommonHandlerRegistry(target, eventName)) : isJQueryStyleEventEmitter(target) ? jqueryMethods.map(toCommonHandlerRegistry(target, eventName)) : [];\n\n if (!add) {\n if (isArrayLike(target)) {\n return mergeMap(subTarget => fromEvent(subTarget, eventName, options))(innerFrom(target));\n }\n }\n\n if (!add) {\n throw new TypeError('Invalid event target');\n }\n\n return new Observable(subscriber => {\n const handler = (...args) => subscriber.next(1 < args.length ? args : args[0]);\n\n add(handler);\n return () => remove(handler);\n });\n}\n\nfunction toCommonHandlerRegistry(target, eventName) {\n return methodName => handler => target[methodName](eventName, handler);\n}\n\nfunction isNodeStyleEventEmitter(target) {\n return isFunction(target.addListener) && isFunction(target.removeListener);\n}\n\nfunction isJQueryStyleEventEmitter(target) {\n return isFunction(target.on) && isFunction(target.off);\n}\n\nfunction isEventTarget(target) {\n return isFunction(target.addEventListener) && isFunction(target.removeEventListener);\n} //# sourceMappingURL=fromEvent.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"export function isValidDate(value) {\n return value instanceof Date && !isNaN(value);\n} //# sourceMappingURL=isDate.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { config } from '../config';\nimport { timeoutProvider } from '../scheduler/timeoutProvider';\nexport function reportUnhandledError(err) {\n timeoutProvider.setTimeout(() => {\n const {\n onUnhandledError\n } = config;\n\n if (onUnhandledError) {\n onUnhandledError(err);\n } else {\n throw err;\n }\n });\n} //# sourceMappingURL=reportUnhandledError.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Subject } from '../Subject';\nimport { Observable } from '../Observable';\nimport { defer } from './defer';\nconst DEFAULT_CONFIG = {\n connector: () => new Subject(),\n resetOnDisconnect: true\n};\nexport function connectable(source, config = DEFAULT_CONFIG) {\n let connection = null;\n const {\n connector,\n resetOnDisconnect = true\n } = config;\n let subject = connector();\n const result = new Observable(subscriber => {\n return subject.subscribe(subscriber);\n });\n\n result.connect = () => {\n if (!connection || connection.closed) {\n connection = defer(() => source).subscribe(subject);\n\n if (resetOnDisconnect) {\n connection.add(() => subject = connector());\n }\n }\n\n return connection;\n };\n\n return result;\n} //# sourceMappingURL=connectable.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { switchMap } from './switchMap';\nimport { isFunction } from '../util/isFunction';\nexport function switchMapTo(innerObservable, resultSelector) {\n return isFunction(resultSelector) ? switchMap(() => innerObservable, resultSelector) : switchMap(() => innerObservable);\n} //# sourceMappingURL=switchMapTo.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Notification } from '../Notification';\nimport { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function materialize() {\n return operate((source, subscriber) => {\n source.subscribe(new OperatorSubscriber(subscriber, value => {\n subscriber.next(Notification.createNext(value));\n }, () => {\n subscriber.next(Notification.createComplete());\n subscriber.complete();\n }, err => {\n subscriber.next(Notification.createError(err));\n subscriber.complete();\n }));\n });\n} //# sourceMappingURL=materialize.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Subject } from '../Subject';\nimport { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nimport { noop } from '../util/noop';\nexport function window(windowBoundaries) {\n return operate((source, subscriber) => {\n let windowSubject = new Subject();\n subscriber.next(windowSubject.asObservable());\n\n const errorHandler = err => {\n windowSubject.error(err);\n subscriber.error(err);\n };\n\n source.subscribe(new OperatorSubscriber(subscriber, value => windowSubject === null || windowSubject === void 0 ? void 0 : windowSubject.next(value), () => {\n windowSubject.complete();\n subscriber.complete();\n }, errorHandler));\n windowBoundaries.subscribe(new OperatorSubscriber(subscriber, () => {\n windowSubject.complete();\n subscriber.next(windowSubject = new Subject());\n }, noop, errorHandler));\n return () => {\n windowSubject === null || windowSubject === void 0 ? void 0 : windowSubject.unsubscribe();\n windowSubject = null;\n };\n });\n} //# sourceMappingURL=window.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { isScheduler } from '../util/isScheduler';\nimport { Observable } from '../Observable';\nimport { subscribeOn } from '../operators/subscribeOn';\nimport { mapOneOrManyArgs } from '../util/mapOneOrManyArgs';\nimport { observeOn } from '../operators/observeOn';\nimport { AsyncSubject } from '../AsyncSubject';\nexport function bindCallbackInternals(isNodeStyle, callbackFunc, resultSelector, scheduler) {\n if (resultSelector) {\n if (isScheduler(resultSelector)) {\n scheduler = resultSelector;\n } else {\n return function (...args) {\n return bindCallbackInternals(isNodeStyle, callbackFunc, scheduler).apply(this, args).pipe(mapOneOrManyArgs(resultSelector));\n };\n }\n }\n\n if (scheduler) {\n return function (...args) {\n return bindCallbackInternals(isNodeStyle, callbackFunc).apply(this, args).pipe(subscribeOn(scheduler), observeOn(scheduler));\n };\n }\n\n return function (...args) {\n const subject = new AsyncSubject();\n let uninitialized = true;\n return new Observable(subscriber => {\n const subs = subject.subscribe(subscriber);\n\n if (uninitialized) {\n uninitialized = false;\n let isAsync = false;\n let isComplete = false;\n callbackFunc.apply(this, [...args, (...results) => {\n if (isNodeStyle) {\n const err = results.shift();\n\n if (err != null) {\n subject.error(err);\n return;\n }\n }\n\n subject.next(1 < results.length ? results : results[0]);\n isComplete = true;\n\n if (isAsync) {\n subject.complete();\n }\n }]);\n\n if (isComplete) {\n subject.complete();\n }\n\n isAsync = true;\n }\n\n return subs;\n });\n };\n} //# sourceMappingURL=bindCallbackInternals.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { asyncScheduler } from '../scheduler/async';\nimport { delayWhen } from './delayWhen';\nimport { timer } from '../observable/timer';\nexport function delay(due, scheduler = asyncScheduler) {\n const duration = timer(due, scheduler);\n return delayWhen(() => duration);\n} //# sourceMappingURL=delay.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import logger from \"../modules/logger/index.js\";\nvar name = \"webpack-dev-server\"; // default level is set on the client side, so it does not need\n// to be set by the CLI or API\n\nvar defaultLevel = \"info\"; // options new options, merge with old options\n\n/**\n * @param {false | true | \"none\" | \"error\" | \"warn\" | \"info\" | \"log\" | \"verbose\"} level\n * @returns {void}\n */\n\nfunction setLogLevel(level) {\n logger.configureDefaultLogger({\n level: level\n });\n}\n\nsetLogLevel(defaultLevel);\nvar log = logger.getLogger(name);\nexport { log, setLogLevel };","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { createErrorClass } from './createErrorClass';\nexport const ObjectUnsubscribedError = createErrorClass(_super => function ObjectUnsubscribedErrorImpl() {\n _super(this);\n\n this.name = 'ObjectUnsubscribedError';\n this.message = 'object unsubscribed';\n}); //# sourceMappingURL=ObjectUnsubscribedError.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { AsyncAction } from './AsyncAction';\nimport { immediateProvider } from './immediateProvider';\nexport class AsapAction extends AsyncAction {\n constructor(scheduler, work) {\n super(scheduler, work);\n this.scheduler = scheduler;\n this.work = work;\n }\n\n requestAsyncId(scheduler, id, delay = 0) {\n if (delay !== null && delay > 0) {\n return super.requestAsyncId(scheduler, id, delay);\n }\n\n scheduler.actions.push(this);\n return scheduler._scheduled || (scheduler._scheduled = immediateProvider.setImmediate(scheduler.flush.bind(scheduler, undefined)));\n }\n\n recycleAsyncId(scheduler, id, delay = 0) {\n if (delay != null && delay > 0 || delay == null && this.delay > 0) {\n return super.recycleAsyncId(scheduler, id, delay);\n }\n\n if (!scheduler.actions.some(action => action.id === id)) {\n immediateProvider.clearImmediate(id);\n scheduler._scheduled = undefined;\n }\n\n return undefined;\n }\n\n} //# sourceMappingURL=AsapAction.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function filter(predicate, thisArg) {\n return operate((source, subscriber) => {\n let index = 0;\n source.subscribe(new OperatorSubscriber(subscriber, value => predicate.call(thisArg, value, index++) && subscriber.next(value)));\n });\n} //# sourceMappingURL=filter.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { defer } from './defer';\nexport function iif(condition, trueResult, falseResult) {\n return defer(() => condition() ? trueResult : falseResult);\n} //# sourceMappingURL=iif.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { concat } from '../observable/concat';\nimport { of } from '../observable/of';\nexport function endWith(...values) {\n return source => concat(source, of(...values));\n} //# sourceMappingURL=endWith.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { scheduled } from '../scheduled/scheduled';\nimport { innerFrom } from './innerFrom';\nexport function from(input, scheduler) {\n return scheduler ? scheduled(input, scheduler) : innerFrom(input);\n} //# sourceMappingURL=from.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { innerFrom } from '../observable/innerFrom';\nimport { Subject } from '../Subject';\nimport { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function groupBy(keySelector, elementOrOptions, duration, connector) {\n return operate((source, subscriber) => {\n let element;\n\n if (!elementOrOptions || typeof elementOrOptions === 'function') {\n element = elementOrOptions;\n } else {\n ({\n duration,\n element,\n connector\n } = elementOrOptions);\n }\n\n const groups = new Map();\n\n const notify = cb => {\n groups.forEach(cb);\n cb(subscriber);\n };\n\n const handleError = err => notify(consumer => consumer.error(err));\n\n const groupBySourceSubscriber = new GroupBySubscriber(subscriber, value => {\n try {\n const key = keySelector(value);\n let group = groups.get(key);\n\n if (!group) {\n groups.set(key, group = connector ? connector() : new Subject());\n const grouped = createGroupedObservable(key, group);\n subscriber.next(grouped);\n\n if (duration) {\n const durationSubscriber = new OperatorSubscriber(group, () => {\n group.complete();\n durationSubscriber === null || durationSubscriber === void 0 ? void 0 : durationSubscriber.unsubscribe();\n }, undefined, undefined, () => groups.delete(key));\n groupBySourceSubscriber.add(innerFrom(duration(grouped)).subscribe(durationSubscriber));\n }\n }\n\n group.next(element ? element(value) : value);\n } catch (err) {\n handleError(err);\n }\n }, () => notify(consumer => consumer.complete()), handleError, () => groups.clear());\n source.subscribe(groupBySourceSubscriber);\n\n function createGroupedObservable(key, groupSubject) {\n const result = new Observable(groupSubscriber => {\n groupBySourceSubscriber.activeGroups++;\n const innerSub = groupSubject.subscribe(groupSubscriber);\n return () => {\n innerSub.unsubscribe();\n --groupBySourceSubscriber.activeGroups === 0 && groupBySourceSubscriber.teardownAttempted && groupBySourceSubscriber.unsubscribe();\n };\n });\n result.key = key;\n return result;\n }\n });\n}\n\nclass GroupBySubscriber extends OperatorSubscriber {\n constructor() {\n super(...arguments);\n this.activeGroups = 0;\n this.teardownAttempted = false;\n }\n\n unsubscribe() {\n this.teardownAttempted = true;\n this.activeGroups === 0 && super.unsubscribe();\n }\n\n} //# sourceMappingURL=groupBy.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { __decorate } from \"tslib\";\nimport { NgModule } from '@angular/core';\nimport { BrowserModule } from '@angular/platform-browser';\nimport { AppRoutingModule } from './app-routing.module';\nimport { AppComponent } from './app.component';\nimport { PinchZoomModule } from 'ngx-pinch-zoom';\nlet AppModule = class AppModule {};\nAppModule = __decorate([NgModule({\n declarations: [AppComponent],\n imports: [BrowserModule, AppRoutingModule, PinchZoomModule],\n providers: [],\n bootstrap: [AppComponent]\n})], AppModule);\nexport { AppModule };","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { Subscription } from '../Subscription';\nimport { refCount as higherOrderRefCount } from '../operators/refCount';\nimport { OperatorSubscriber } from '../operators/OperatorSubscriber';\nimport { hasLift } from '../util/lift';\nexport class ConnectableObservable extends Observable {\n constructor(source, subjectFactory) {\n super();\n this.source = source;\n this.subjectFactory = subjectFactory;\n this._subject = null;\n this._refCount = 0;\n this._connection = null;\n\n if (hasLift(source)) {\n this.lift = source.lift;\n }\n }\n\n _subscribe(subscriber) {\n return this.getSubject().subscribe(subscriber);\n }\n\n getSubject() {\n const subject = this._subject;\n\n if (!subject || subject.isStopped) {\n this._subject = this.subjectFactory();\n }\n\n return this._subject;\n }\n\n _teardown() {\n this._refCount = 0;\n const {\n _connection\n } = this;\n this._subject = this._connection = null;\n _connection === null || _connection === void 0 ? void 0 : _connection.unsubscribe();\n }\n\n connect() {\n let connection = this._connection;\n\n if (!connection) {\n connection = this._connection = new Subscription();\n const subject = this.getSubject();\n connection.add(this.source.subscribe(new OperatorSubscriber(subject, undefined, () => {\n this._teardown();\n\n subject.complete();\n }, err => {\n this._teardown();\n\n subject.error(err);\n }, () => this._teardown())));\n\n if (connection.closed) {\n this._connection = null;\n connection = Subscription.EMPTY;\n }\n }\n\n return connection;\n }\n\n refCount() {\n return higherOrderRefCount()(this);\n }\n\n} //# sourceMappingURL=ConnectableObservable.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"export function getSymbolIterator() {\n if (typeof Symbol !== 'function' || !Symbol.iterator) {\n return '@@iterator';\n }\n\n return Symbol.iterator;\n}\nexport const iterator = getSymbolIterator(); //# sourceMappingURL=iterator.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { identity } from './identity';\nexport function pipe(...fns) {\n return pipeFromArray(fns);\n}\nexport function pipeFromArray(fns) {\n if (fns.length === 0) {\n return identity;\n }\n\n if (fns.length === 1) {\n return fns[0];\n }\n\n return function piped(input) {\n return fns.reduce((prev, fn) => fn(prev), input);\n };\n} //# sourceMappingURL=pipe.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { switchMap } from './switchMap';\nimport { identity } from '../util/identity';\nexport function switchAll() {\n return switchMap(identity);\n} //# sourceMappingURL=switchAll.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"\"use strict\";\n\nObject.defineProperty(exports, \"__esModule\", {\n value: true\n});\n\nexports.fromCodePoint = String.fromCodePoint || function (astralCodePoint) {\n return String.fromCharCode(Math.floor((astralCodePoint - 65536) / 1024) + 55296, (astralCodePoint - 65536) % 1024 + 56320);\n};\n\nexports.getCodePoint = String.prototype.codePointAt ? function (input, position) {\n return input.codePointAt(position);\n} : function (input, position) {\n return (input.charCodeAt(position) - 55296) * 1024 + input.charCodeAt(position + 1) - 56320 + 65536;\n};\nexports.highSurrogateFrom = 55296;\nexports.highSurrogateTo = 56319;","map":null,"metadata":{},"sourceType":"script"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { reduce } from './reduce';\nexport function count(predicate) {\n return reduce((total, value, i) => !predicate || predicate(value, i) ? total + 1 : total, 0);\n} //# sourceMappingURL=count.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { identity } from '../util/identity';\nimport { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function skipLast(skipCount) {\n return skipCount <= 0 ? identity : operate((source, subscriber) => {\n let ring = new Array(skipCount);\n let seen = 0;\n source.subscribe(new OperatorSubscriber(subscriber, value => {\n const valueIndex = seen++;\n\n if (valueIndex < skipCount) {\n ring[valueIndex] = value;\n } else {\n const index = valueIndex % skipCount;\n const oldValue = ring[index];\n ring[index] = value;\n subscriber.next(oldValue);\n }\n }));\n return () => {\n ring = null;\n };\n });\n} //# sourceMappingURL=skipLast.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { isFunction } from './isFunction';\nexport function isObservable(obj) {\n return !!obj && (obj instanceof Observable || isFunction(obj.lift) && isFunction(obj.subscribe));\n} //# sourceMappingURL=isObservable.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../../Observable';\nimport { Subscription } from '../../Subscription';\nimport { performanceTimestampProvider } from '../../scheduler/performanceTimestampProvider';\nimport { animationFrameProvider } from '../../scheduler/animationFrameProvider';\nexport function animationFrames(timestampProvider) {\n return timestampProvider ? animationFramesFactory(timestampProvider) : DEFAULT_ANIMATION_FRAMES;\n}\n\nfunction animationFramesFactory(timestampProvider) {\n const {\n schedule\n } = animationFrameProvider;\n return new Observable(subscriber => {\n const subscription = new Subscription();\n const provider = timestampProvider || performanceTimestampProvider;\n const start = provider.now();\n\n const run = timestamp => {\n const now = provider.now();\n subscriber.next({\n timestamp: timestampProvider ? now : timestamp,\n elapsed: now - start\n });\n\n if (!subscriber.closed) {\n subscription.add(schedule(run));\n }\n };\n\n subscription.add(schedule(run));\n return subscription;\n });\n}\n\nconst DEFAULT_ANIMATION_FRAMES = animationFramesFactory(); //# sourceMappingURL=animationFrames.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { dateTimestampProvider } from './scheduler/dateTimestampProvider';\nexport class Scheduler {\n constructor(schedulerActionCtor, now = Scheduler.now) {\n this.schedulerActionCtor = schedulerActionCtor;\n this.now = now;\n }\n\n schedule(work, delay = 0, state) {\n return new this.schedulerActionCtor(this, work).schedule(state, delay);\n }\n\n}\nScheduler.now = dateTimestampProvider.now; //# sourceMappingURL=Scheduler.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"export function createErrorClass(createImpl) {\n const _super = instance => {\n Error.call(instance);\n instance.stack = new Error().stack;\n };\n\n const ctorFunc = createImpl(_super);\n ctorFunc.prototype = Object.create(Error.prototype);\n ctorFunc.prototype.constructor = ctorFunc;\n return ctorFunc;\n} //# sourceMappingURL=createErrorClass.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { merge } from './merge';\nexport function mergeWith(...otherSources) {\n return merge(...otherSources);\n} //# sourceMappingURL=mergeWith.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Scheduler } from '../Scheduler';\nexport class AsyncScheduler extends Scheduler {\n constructor(SchedulerAction, now = Scheduler.now) {\n super(SchedulerAction, now);\n this.actions = [];\n this._active = false;\n this._scheduled = undefined;\n }\n\n flush(action) {\n const {\n actions\n } = this;\n\n if (this._active) {\n actions.push(action);\n return;\n }\n\n let error;\n this._active = true;\n\n do {\n if (error = action.execute(action.state, action.delay)) {\n break;\n }\n } while (action = actions.shift());\n\n this._active = false;\n\n if (error) {\n while (action = actions.shift()) {\n action.unsubscribe();\n }\n\n throw error;\n }\n }\n\n} //# sourceMappingURL=AsyncScheduler.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { isFunction } from './isFunction';\nimport { isScheduler } from './isScheduler';\n\nfunction last(arr) {\n return arr[arr.length - 1];\n}\n\nexport function popResultSelector(args) {\n return isFunction(last(args)) ? args.pop() : undefined;\n}\nexport function popScheduler(args) {\n return isScheduler(last(args)) ? args.pop() : undefined;\n}\nexport function popNumber(args, defaultValue) {\n return typeof last(args) === 'number' ? args.pop() : defaultValue;\n} //# sourceMappingURL=args.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { operate } from '../util/lift';\nimport { scanInternals } from './scanInternals';\nexport function scan(accumulator, seed) {\n return operate(scanInternals(accumulator, seed, arguments.length >= 2, true));\n} //# sourceMappingURL=scan.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { argsArgArrayOrObject } from '../util/argsArgArrayOrObject';\nimport { from } from './from';\nimport { identity } from '../util/identity';\nimport { mapOneOrManyArgs } from '../util/mapOneOrManyArgs';\nimport { popResultSelector, popScheduler } from '../util/args';\nimport { createObject } from '../util/createObject';\nimport { OperatorSubscriber } from '../operators/OperatorSubscriber';\nimport { executeSchedule } from '../util/executeSchedule';\nexport function combineLatest(...args) {\n const scheduler = popScheduler(args);\n const resultSelector = popResultSelector(args);\n const {\n args: observables,\n keys\n } = argsArgArrayOrObject(args);\n\n if (observables.length === 0) {\n return from([], scheduler);\n }\n\n const result = new Observable(combineLatestInit(observables, scheduler, keys ? values => createObject(keys, values) : identity));\n return resultSelector ? result.pipe(mapOneOrManyArgs(resultSelector)) : result;\n}\nexport function combineLatestInit(observables, scheduler, valueTransform = identity) {\n return subscriber => {\n maybeSchedule(scheduler, () => {\n const {\n length\n } = observables;\n const values = new Array(length);\n let active = length;\n let remainingFirstValues = length;\n\n for (let i = 0; i < length; i++) {\n maybeSchedule(scheduler, () => {\n const source = from(observables[i], scheduler);\n let hasFirstValue = false;\n source.subscribe(new OperatorSubscriber(subscriber, value => {\n values[i] = value;\n\n if (!hasFirstValue) {\n hasFirstValue = true;\n remainingFirstValues--;\n }\n\n if (!remainingFirstValues) {\n subscriber.next(valueTransform(values.slice()));\n }\n }, () => {\n if (! --active) {\n subscriber.complete();\n }\n }));\n }, subscriber);\n }\n }, subscriber);\n };\n}\n\nfunction maybeSchedule(scheduler, execute, subscription) {\n if (scheduler) {\n executeSchedule(subscription, scheduler, execute);\n } else {\n execute();\n }\n} //# sourceMappingURL=combineLatest.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { isFunction } from './util/isFunction';\nimport { UnsubscriptionError } from './util/UnsubscriptionError';\nimport { arrRemove } from './util/arrRemove';\nexport class Subscription {\n constructor(initialTeardown) {\n this.initialTeardown = initialTeardown;\n this.closed = false;\n this._parentage = null;\n this._teardowns = null;\n }\n\n unsubscribe() {\n let errors;\n\n if (!this.closed) {\n this.closed = true;\n const {\n _parentage\n } = this;\n\n if (_parentage) {\n this._parentage = null;\n\n if (Array.isArray(_parentage)) {\n for (const parent of _parentage) {\n parent.remove(this);\n }\n } else {\n _parentage.remove(this);\n }\n }\n\n const {\n initialTeardown\n } = this;\n\n if (isFunction(initialTeardown)) {\n try {\n initialTeardown();\n } catch (e) {\n errors = e instanceof UnsubscriptionError ? e.errors : [e];\n }\n }\n\n const {\n _teardowns\n } = this;\n\n if (_teardowns) {\n this._teardowns = null;\n\n for (const teardown of _teardowns) {\n try {\n execTeardown(teardown);\n } catch (err) {\n errors = errors !== null && errors !== void 0 ? errors : [];\n\n if (err instanceof UnsubscriptionError) {\n errors = [...errors, ...err.errors];\n } else {\n errors.push(err);\n }\n }\n }\n }\n\n if (errors) {\n throw new UnsubscriptionError(errors);\n }\n }\n }\n\n add(teardown) {\n var _a;\n\n if (teardown && teardown !== this) {\n if (this.closed) {\n execTeardown(teardown);\n } else {\n if (teardown instanceof Subscription) {\n if (teardown.closed || teardown._hasParent(this)) {\n return;\n }\n\n teardown._addParent(this);\n }\n\n (this._teardowns = (_a = this._teardowns) !== null && _a !== void 0 ? _a : []).push(teardown);\n }\n }\n }\n\n _hasParent(parent) {\n const {\n _parentage\n } = this;\n return _parentage === parent || Array.isArray(_parentage) && _parentage.includes(parent);\n }\n\n _addParent(parent) {\n const {\n _parentage\n } = this;\n this._parentage = Array.isArray(_parentage) ? (_parentage.push(parent), _parentage) : _parentage ? [_parentage, parent] : parent;\n }\n\n _removeParent(parent) {\n const {\n _parentage\n } = this;\n\n if (_parentage === parent) {\n this._parentage = null;\n } else if (Array.isArray(_parentage)) {\n arrRemove(_parentage, parent);\n }\n }\n\n remove(teardown) {\n const {\n _teardowns\n } = this;\n _teardowns && arrRemove(_teardowns, teardown);\n\n if (teardown instanceof Subscription) {\n teardown._removeParent(this);\n }\n }\n\n}\n\nSubscription.EMPTY = (() => {\n const empty = new Subscription();\n empty.closed = true;\n return empty;\n})();\n\nexport const EMPTY_SUBSCRIPTION = Subscription.EMPTY;\nexport function isSubscription(value) {\n return value instanceof Subscription || value && 'closed' in value && isFunction(value.remove) && isFunction(value.add) && isFunction(value.unsubscribe);\n}\n\nfunction execTeardown(teardown) {\n if (isFunction(teardown)) {\n teardown();\n } else {\n teardown.unsubscribe();\n }\n} //# sourceMappingURL=Subscription.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { innerFrom } from '../observable/innerFrom';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nimport { operate } from '../util/lift';\nexport function catchError(selector) {\n return operate((source, subscriber) => {\n let innerSub = null;\n let syncUnsub = false;\n let handledResult;\n innerSub = source.subscribe(new OperatorSubscriber(subscriber, undefined, undefined, err => {\n handledResult = innerFrom(selector(err, catchError(selector)(source)));\n\n if (innerSub) {\n innerSub.unsubscribe();\n innerSub = null;\n handledResult.subscribe(subscriber);\n } else {\n syncUnsub = true;\n }\n }));\n\n if (syncUnsub) {\n innerSub.unsubscribe();\n innerSub = null;\n handledResult.subscribe(subscriber);\n }\n });\n} //# sourceMappingURL=catchError.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Subject } from './Subject';\nexport class AsyncSubject extends Subject {\n constructor() {\n super(...arguments);\n this._value = null;\n this._hasValue = false;\n this._isComplete = false;\n }\n\n _checkFinalizedStatuses(subscriber) {\n const {\n hasError,\n _hasValue,\n _value,\n thrownError,\n isStopped,\n _isComplete\n } = this;\n\n if (hasError) {\n subscriber.error(thrownError);\n } else if (isStopped || _isComplete) {\n _hasValue && subscriber.next(_value);\n subscriber.complete();\n }\n }\n\n next(value) {\n if (!this.isStopped) {\n this._value = value;\n this._hasValue = true;\n }\n }\n\n complete() {\n const {\n _hasValue,\n _value,\n _isComplete\n } = this;\n\n if (!_isComplete) {\n this._isComplete = true;\n _hasValue && super.next(_value);\n super.complete();\n }\n }\n\n} //# sourceMappingURL=AsyncSubject.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function sequenceEqual(compareTo, comparator = (a, b) => a === b) {\n return operate((source, subscriber) => {\n const aState = createState();\n const bState = createState();\n\n const emit = isEqual => {\n subscriber.next(isEqual);\n subscriber.complete();\n };\n\n const createSubscriber = (selfState, otherState) => {\n const sequenceEqualSubscriber = new OperatorSubscriber(subscriber, a => {\n const {\n buffer,\n complete\n } = otherState;\n\n if (buffer.length === 0) {\n complete ? emit(false) : selfState.buffer.push(a);\n } else {\n !comparator(a, buffer.shift()) && emit(false);\n }\n }, () => {\n selfState.complete = true;\n const {\n complete,\n buffer\n } = otherState;\n complete && emit(buffer.length === 0);\n sequenceEqualSubscriber === null || sequenceEqualSubscriber === void 0 ? void 0 : sequenceEqualSubscriber.unsubscribe();\n });\n return sequenceEqualSubscriber;\n };\n\n source.subscribe(createSubscriber(aState, bState));\n compareTo.subscribe(createSubscriber(bState, aState));\n });\n}\n\nfunction createState() {\n return {\n buffer: [],\n complete: false\n };\n} //# sourceMappingURL=sequenceEqual.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { ArgumentOutOfRangeError } from '../util/ArgumentOutOfRangeError';\nimport { filter } from './filter';\nimport { throwIfEmpty } from './throwIfEmpty';\nimport { defaultIfEmpty } from './defaultIfEmpty';\nimport { take } from './take';\nexport function elementAt(index, defaultValue) {\n if (index < 0) {\n throw new ArgumentOutOfRangeError();\n }\n\n const hasDefaultValue = arguments.length >= 2;\n return source => source.pipe(filter((v, i) => i === index), take(1), hasDefaultValue ? defaultIfEmpty(defaultValue) : throwIfEmpty(() => new ArgumentOutOfRangeError()));\n} //# sourceMappingURL=elementAt.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function defaultIfEmpty(defaultValue) {\n return operate((source, subscriber) => {\n let hasValue = false;\n source.subscribe(new OperatorSubscriber(subscriber, value => {\n hasValue = true;\n subscriber.next(value);\n }, () => {\n if (!hasValue) {\n subscriber.next(defaultValue);\n }\n\n subscriber.complete();\n }));\n });\n} //# sourceMappingURL=defaultIfEmpty.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { concat } from './concat';\nexport function concatWith(...otherSources) {\n return concat(...otherSources);\n} //# sourceMappingURL=concatWith.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { config } from '../config';\nlet context = null;\nexport function errorContext(cb) {\n if (config.useDeprecatedSynchronousErrorHandling) {\n const isRoot = !context;\n\n if (isRoot) {\n context = {\n errorThrown: false,\n error: null\n };\n }\n\n cb();\n\n if (isRoot) {\n const {\n errorThrown,\n error\n } = context;\n context = null;\n\n if (errorThrown) {\n throw error;\n }\n }\n } else {\n cb();\n }\n}\nexport function captureError(err) {\n if (config.useDeprecatedSynchronousErrorHandling && context) {\n context.errorThrown = true;\n context.error = err;\n }\n} //# sourceMappingURL=errorContext.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Subject } from '../Subject';\nimport { from } from '../observable/from';\nimport { operate } from '../util/lift';\nimport { fromSubscribable } from '../observable/fromSubscribable';\nconst DEFAULT_CONFIG = {\n connector: () => new Subject()\n};\nexport function connect(selector, config = DEFAULT_CONFIG) {\n const {\n connector\n } = config;\n return operate((source, subscriber) => {\n const subject = connector();\n from(selector(fromSubscribable(subject))).subscribe(subscriber);\n subscriber.add(source.subscribe(subject));\n });\n} //# sourceMappingURL=connect.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { asyncScheduler } from '../scheduler/async';\nimport { isValidDate } from '../util/isDate';\nimport { operate } from '../util/lift';\nimport { innerFrom } from '../observable/innerFrom';\nimport { createErrorClass } from '../util/createErrorClass';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nimport { executeSchedule } from '../util/executeSchedule';\nexport const TimeoutError = createErrorClass(_super => function TimeoutErrorImpl(info = null) {\n _super(this);\n\n this.message = 'Timeout has occurred';\n this.name = 'TimeoutError';\n this.info = info;\n});\nexport function timeout(config, schedulerArg) {\n const {\n first,\n each,\n with: _with = timeoutErrorFactory,\n scheduler = schedulerArg !== null && schedulerArg !== void 0 ? schedulerArg : asyncScheduler,\n meta = null\n } = isValidDate(config) ? {\n first: config\n } : typeof config === 'number' ? {\n each: config\n } : config;\n\n if (first == null && each == null) {\n throw new TypeError('No timeout provided.');\n }\n\n return operate((source, subscriber) => {\n let originalSourceSubscription;\n let timerSubscription;\n let lastValue = null;\n let seen = 0;\n\n const startTimer = delay => {\n timerSubscription = executeSchedule(subscriber, scheduler, () => {\n try {\n originalSourceSubscription.unsubscribe();\n innerFrom(_with({\n meta,\n lastValue,\n seen\n })).subscribe(subscriber);\n } catch (err) {\n subscriber.error(err);\n }\n }, delay);\n };\n\n originalSourceSubscription = source.subscribe(new OperatorSubscriber(subscriber, value => {\n timerSubscription === null || timerSubscription === void 0 ? void 0 : timerSubscription.unsubscribe();\n seen++;\n subscriber.next(lastValue = value);\n each > 0 && startTimer(each);\n }, undefined, undefined, () => {\n if (!(timerSubscription === null || timerSubscription === void 0 ? void 0 : timerSubscription.closed)) {\n timerSubscription === null || timerSubscription === void 0 ? void 0 : timerSubscription.unsubscribe();\n }\n\n lastValue = null;\n }));\n startTimer(first != null ? typeof first === 'number' ? first : +first - scheduler.now() : each);\n });\n}\n\nfunction timeoutErrorFactory(info) {\n throw new TimeoutError(info);\n} //# sourceMappingURL=timeout.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { isFunction } from '../util/isFunction';\nimport { mapOneOrManyArgs } from '../util/mapOneOrManyArgs';\nexport function fromEventPattern(addHandler, removeHandler, resultSelector) {\n if (resultSelector) {\n return fromEventPattern(addHandler, removeHandler).pipe(mapOneOrManyArgs(resultSelector));\n }\n\n return new Observable(subscriber => {\n const handler = (...e) => subscriber.next(e.length === 1 ? e[0] : e);\n\n const retValue = addHandler(handler);\n return isFunction(removeHandler) ? () => removeHandler(handler, retValue) : undefined;\n });\n} //# sourceMappingURL=fromEventPattern.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { bindCallbackInternals } from './bindCallbackInternals';\nexport function bindCallback(callbackFunc, resultSelector, scheduler) {\n return bindCallbackInternals(false, callbackFunc, resultSelector, scheduler);\n} //# sourceMappingURL=bindCallback.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { observeNotification } from '../Notification';\nimport { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function dematerialize() {\n return operate((source, subscriber) => {\n source.subscribe(new OperatorSubscriber(subscriber, notification => observeNotification(notification, subscriber)));\n });\n} //# sourceMappingURL=dematerialize.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { asyncScheduler } from '../scheduler/async';\nimport { defaultThrottleConfig, throttle } from './throttle';\nimport { timer } from '../observable/timer';\nexport function throttleTime(duration, scheduler = asyncScheduler, config = defaultThrottleConfig) {\n const duration$ = timer(duration, scheduler);\n return throttle(() => duration$, config);\n} //# sourceMappingURL=throttleTime.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { createErrorClass } from './createErrorClass';\nexport const EmptyError = createErrorClass(_super => function EmptyErrorImpl() {\n _super(this);\n\n this.name = 'EmptyError';\n this.message = 'no elements in sequence';\n}); //# sourceMappingURL=EmptyError.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { CommonModule } from '@angular/common';\nimport * as i0 from \"@angular/core\";\nexport let PinchZoomModule = /*#__PURE__*/(() => {\n class PinchZoomModule {}\n\n PinchZoomModule.ɵfac = function PinchZoomModule_Factory(t) {\n return new (t || PinchZoomModule)();\n };\n\n PinchZoomModule.ɵmod = /*@__PURE__*/i0.ɵɵdefineNgModule({\n type: PinchZoomModule\n });\n PinchZoomModule.ɵinj = /*@__PURE__*/i0.ɵɵdefineInjector({\n providers: [],\n imports: [[CommonModule]]\n });\n return PinchZoomModule;\n})();","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { async as asyncScheduler } from '../scheduler/async';\nimport { isScheduler } from '../util/isScheduler';\nimport { isValidDate } from '../util/isDate';\nexport function timer(dueTime = 0, intervalOrScheduler, scheduler = asyncScheduler) {\n let intervalDuration = -1;\n\n if (intervalOrScheduler != null) {\n if (isScheduler(intervalOrScheduler)) {\n scheduler = intervalOrScheduler;\n } else {\n intervalDuration = intervalOrScheduler;\n }\n }\n\n return new Observable(subscriber => {\n let due = isValidDate(dueTime) ? +dueTime - scheduler.now() : dueTime;\n\n if (due < 0) {\n due = 0;\n }\n\n let n = 0;\n return scheduler.schedule(function () {\n if (!subscriber.closed) {\n subscriber.next(n++);\n\n if (0 <= intervalDuration) {\n this.schedule(undefined, intervalDuration);\n } else {\n subscriber.complete();\n }\n }\n }, due);\n });\n} //# sourceMappingURL=timer.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { asyncScheduler } from '../scheduler/async';\nimport { sample } from './sample';\nimport { interval } from '../observable/interval';\nexport function sampleTime(period, scheduler = asyncScheduler) {\n return sample(interval(period, scheduler));\n} //# sourceMappingURL=sampleTime.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { innerFrom } from './innerFrom';\nimport { argsOrArgArray } from '../util/argsOrArgArray';\nimport { OperatorSubscriber } from '../operators/OperatorSubscriber';\nexport function race(...sources) {\n sources = argsOrArgArray(sources);\n return sources.length === 1 ? innerFrom(sources[0]) : new Observable(raceInit(sources));\n}\nexport function raceInit(sources) {\n return subscriber => {\n let subscriptions = [];\n\n for (let i = 0; subscriptions && !subscriber.closed && i < sources.length; i++) {\n subscriptions.push(innerFrom(sources[i]).subscribe(new OperatorSubscriber(subscriber, value => {\n if (subscriptions) {\n for (let s = 0; s < subscriptions.length; s++) {\n s !== i && subscriptions[s].unsubscribe();\n }\n\n subscriptions = null;\n }\n\n subscriber.next(value);\n })));\n }\n };\n} //# sourceMappingURL=race.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { popScheduler } from '../util/args';\nimport { from } from './from';\nexport function of(...args) {\n const scheduler = popScheduler(args);\n return from(args, scheduler);\n} //# sourceMappingURL=of.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { innerFrom } from './innerFrom';\nimport { EMPTY } from './empty';\nexport function using(resourceFactory, observableFactory) {\n return new Observable(subscriber => {\n const resource = resourceFactory();\n const result = observableFactory(resource);\n const source = result ? innerFrom(result) : EMPTY;\n source.subscribe(subscriber);\n return () => {\n if (resource) {\n resource.unsubscribe();\n }\n };\n });\n} //# sourceMappingURL=using.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { mergeAll } from '../operators/mergeAll';\nimport { innerFrom } from './innerFrom';\nimport { EMPTY } from './empty';\nimport { popNumber, popScheduler } from '../util/args';\nimport { from } from './from';\nexport function merge(...args) {\n const scheduler = popScheduler(args);\n const concurrent = popNumber(args, Infinity);\n const sources = args;\n return !sources.length ? EMPTY : sources.length === 1 ? innerFrom(sources[0]) : mergeAll(concurrent)(from(sources, scheduler));\n} //# sourceMappingURL=merge.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { __asyncValues, __awaiter } from \"tslib\";\nimport { isArrayLike } from '../util/isArrayLike';\nimport { isPromise } from '../util/isPromise';\nimport { Observable } from '../Observable';\nimport { isInteropObservable } from '../util/isInteropObservable';\nimport { isAsyncIterable } from '../util/isAsyncIterable';\nimport { createInvalidObservableTypeError } from '../util/throwUnobservableError';\nimport { isIterable } from '../util/isIterable';\nimport { isReadableStreamLike, readableStreamLikeToAsyncGenerator } from '../util/isReadableStreamLike';\nimport { isFunction } from '../util/isFunction';\nimport { reportUnhandledError } from '../util/reportUnhandledError';\nimport { observable as Symbol_observable } from '../symbol/observable';\nexport function innerFrom(input) {\n if (input instanceof Observable) {\n return input;\n }\n\n if (input != null) {\n if (isInteropObservable(input)) {\n return fromInteropObservable(input);\n }\n\n if (isArrayLike(input)) {\n return fromArrayLike(input);\n }\n\n if (isPromise(input)) {\n return fromPromise(input);\n }\n\n if (isAsyncIterable(input)) {\n return fromAsyncIterable(input);\n }\n\n if (isIterable(input)) {\n return fromIterable(input);\n }\n\n if (isReadableStreamLike(input)) {\n return fromReadableStreamLike(input);\n }\n }\n\n throw createInvalidObservableTypeError(input);\n}\nexport function fromInteropObservable(obj) {\n return new Observable(subscriber => {\n const obs = obj[Symbol_observable]();\n\n if (isFunction(obs.subscribe)) {\n return obs.subscribe(subscriber);\n }\n\n throw new TypeError('Provided object does not correctly implement Symbol.observable');\n });\n}\nexport function fromArrayLike(array) {\n return new Observable(subscriber => {\n for (let i = 0; i < array.length && !subscriber.closed; i++) {\n subscriber.next(array[i]);\n }\n\n subscriber.complete();\n });\n}\nexport function fromPromise(promise) {\n return new Observable(subscriber => {\n promise.then(value => {\n if (!subscriber.closed) {\n subscriber.next(value);\n subscriber.complete();\n }\n }, err => subscriber.error(err)).then(null, reportUnhandledError);\n });\n}\nexport function fromIterable(iterable) {\n return new Observable(subscriber => {\n for (const value of iterable) {\n subscriber.next(value);\n\n if (subscriber.closed) {\n return;\n }\n }\n\n subscriber.complete();\n });\n}\nexport function fromAsyncIterable(asyncIterable) {\n return new Observable(subscriber => {\n process(asyncIterable, subscriber).catch(err => subscriber.error(err));\n });\n}\nexport function fromReadableStreamLike(readableStream) {\n return fromAsyncIterable(readableStreamLikeToAsyncGenerator(readableStream));\n}\n\nfunction process(asyncIterable, subscriber) {\n var asyncIterable_1, asyncIterable_1_1;\n\n var e_1, _a;\n\n return __awaiter(this, void 0, void 0, function* () {\n try {\n for (asyncIterable_1 = __asyncValues(asyncIterable); asyncIterable_1_1 = yield asyncIterable_1.next(), !asyncIterable_1_1.done;) {\n const value = asyncIterable_1_1.value;\n subscriber.next(value);\n\n if (subscriber.closed) {\n return;\n }\n }\n } catch (e_1_1) {\n e_1 = {\n error: e_1_1\n };\n } finally {\n try {\n if (asyncIterable_1_1 && !asyncIterable_1_1.done && (_a = asyncIterable_1.return)) yield _a.call(asyncIterable_1);\n } finally {\n if (e_1) throw e_1.error;\n }\n }\n\n subscriber.complete();\n });\n} //# sourceMappingURL=innerFrom.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"export function isFunction(value) {\n return typeof value === 'function';\n} //# sourceMappingURL=isFunction.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Action } from './Action';\nimport { intervalProvider } from './intervalProvider';\nimport { arrRemove } from '../util/arrRemove';\nexport class AsyncAction extends Action {\n constructor(scheduler, work) {\n super(scheduler, work);\n this.scheduler = scheduler;\n this.work = work;\n this.pending = false;\n }\n\n schedule(state, delay = 0) {\n if (this.closed) {\n return this;\n }\n\n this.state = state;\n const id = this.id;\n const scheduler = this.scheduler;\n\n if (id != null) {\n this.id = this.recycleAsyncId(scheduler, id, delay);\n }\n\n this.pending = true;\n this.delay = delay;\n this.id = this.id || this.requestAsyncId(scheduler, this.id, delay);\n return this;\n }\n\n requestAsyncId(scheduler, _id, delay = 0) {\n return intervalProvider.setInterval(scheduler.flush.bind(scheduler, this), delay);\n }\n\n recycleAsyncId(_scheduler, id, delay = 0) {\n if (delay != null && this.delay === delay && this.pending === false) {\n return id;\n }\n\n intervalProvider.clearInterval(id);\n return undefined;\n }\n\n execute(state, delay) {\n if (this.closed) {\n return new Error('executing a cancelled action');\n }\n\n this.pending = false;\n\n const error = this._execute(state, delay);\n\n if (error) {\n return error;\n } else if (this.pending === false && this.id != null) {\n this.id = this.recycleAsyncId(this.scheduler, this.id, null);\n }\n }\n\n _execute(state, _delay) {\n let errored = false;\n let errorValue;\n\n try {\n this.work(state);\n } catch (e) {\n errored = true;\n errorValue = e ? e : new Error('Scheduled action threw falsy error');\n }\n\n if (errored) {\n this.unsubscribe();\n return errorValue;\n }\n }\n\n unsubscribe() {\n if (!this.closed) {\n const {\n id,\n scheduler\n } = this;\n const {\n actions\n } = scheduler;\n this.work = this.state = this.scheduler = null;\n this.pending = false;\n arrRemove(actions, this);\n\n if (id != null) {\n this.id = this.recycleAsyncId(scheduler, id, null);\n }\n\n this.delay = null;\n super.unsubscribe();\n }\n }\n\n} //# sourceMappingURL=AsyncAction.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"var logLevel = \"info\";\n\nfunction dummy() {}\n\nfunction shouldLog(level) {\n var shouldLog = logLevel === \"info\" && level === \"info\" || [\"info\", \"warning\"].indexOf(logLevel) >= 0 && level === \"warning\" || [\"info\", \"warning\", \"error\"].indexOf(logLevel) >= 0 && level === \"error\";\n return shouldLog;\n}\n\nfunction logGroup(logFn) {\n return function (level, msg) {\n if (shouldLog(level)) {\n logFn(msg);\n }\n };\n}\n\nmodule.exports = function (level, msg) {\n if (shouldLog(level)) {\n if (level === \"info\") {\n console.log(msg);\n } else if (level === \"warning\") {\n console.warn(msg);\n } else if (level === \"error\") {\n console.error(msg);\n }\n }\n};\n/* eslint-disable node/no-unsupported-features/node-builtins */\n\n\nvar group = console.group || dummy;\nvar groupCollapsed = console.groupCollapsed || dummy;\nvar groupEnd = console.groupEnd || dummy;\n/* eslint-enable node/no-unsupported-features/node-builtins */\n\nmodule.exports.group = logGroup(group);\nmodule.exports.groupCollapsed = logGroup(groupCollapsed);\nmodule.exports.groupEnd = logGroup(groupEnd);\n\nmodule.exports.setLogLevel = function (level) {\n logLevel = level;\n};\n\nmodule.exports.formatError = function (err) {\n var message = err.message;\n var stack = err.stack;\n\n if (!stack) {\n return message;\n } else if (stack.indexOf(message) < 0) {\n return message + \"\\n\" + stack;\n } else {\n return stack;\n }\n};","map":null,"metadata":{},"sourceType":"script"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { operate } from '../util/lift';\nimport { innerFrom } from '../observable/innerFrom';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function exhaustAll() {\n return operate((source, subscriber) => {\n let isComplete = false;\n let innerSub = null;\n source.subscribe(new OperatorSubscriber(subscriber, inner => {\n if (!innerSub) {\n innerSub = innerFrom(inner).subscribe(new OperatorSubscriber(subscriber, undefined, () => {\n innerSub = null;\n isComplete && subscriber.complete();\n }));\n }\n }, () => {\n isComplete = true;\n !innerSub && subscriber.complete();\n }));\n });\n} //# sourceMappingURL=exhaustAll.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Subject } from '../Subject';\nimport { operate } from '../util/lift';\nimport { OperatorSubscriber } from './OperatorSubscriber';\nexport function retryWhen(notifier) {\n return operate((source, subscriber) => {\n let innerSub;\n let syncResub = false;\n let errors$;\n\n const subscribeForRetryWhen = () => {\n innerSub = source.subscribe(new OperatorSubscriber(subscriber, undefined, undefined, err => {\n if (!errors$) {\n errors$ = new Subject();\n notifier(errors$).subscribe(new OperatorSubscriber(subscriber, () => innerSub ? subscribeForRetryWhen() : syncResub = true));\n }\n\n if (errors$) {\n errors$.next(err);\n }\n }));\n\n if (syncResub) {\n innerSub.unsubscribe();\n innerSub = null;\n syncResub = false;\n subscribeForRetryWhen();\n }\n };\n\n subscribeForRetryWhen();\n });\n} //# sourceMappingURL=retryWhen.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { Observable } from '../Observable';\nimport { isFunction } from '../util/isFunction';\nexport function throwError(errorOrErrorFactory, scheduler) {\n const errorFactory = isFunction(errorOrErrorFactory) ? errorOrErrorFactory : () => errorOrErrorFactory;\n\n const init = subscriber => subscriber.error(errorFactory());\n\n return new Observable(scheduler ? subscriber => scheduler.schedule(init, 0, subscriber) : init);\n} //# sourceMappingURL=throwError.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -1 +0,0 @@
|
||||||
{"ast":null,"code":"import { combineLatest } from './combineLatest';\nexport function combineLatestWith(...otherSources) {\n return combineLatest(...otherSources);\n} //# sourceMappingURL=combineLatestWith.js.map","map":null,"metadata":{},"sourceType":"module"}
|
|
||||||
Some files were not shown because too many files have changed in this diff Show more
Loading…
Add table
Reference in a new issue