X-Git-Url: https://git.josue.xyz/?p=dotfiles%2F.git;a=blobdiff_plain;f=.config%2Fcoc%2Fextensions%2Fnode_modules%2Fcoc-prettier%2Fnode_modules%2Fcore-js%2Fmodules%2Fesnext.observable.js;h=f3bff30fa17cabbbfe4b77b512e2f07e7ec35816;hp=edc52b8a961a24d25f0c41de0e2d1c16f7df23c8;hb=3be0a9efc698a9570a44456009afc6014812625a;hpb=d2f432cc757f42f0318fdddcab8c00b240d47088 diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/core-js/modules/esnext.observable.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/core-js/modules/esnext.observable.js index edc52b8a..f3bff30f 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/core-js/modules/esnext.observable.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/core-js/modules/esnext.observable.js @@ -1,16 +1,21 @@ 'use strict'; // https://github.com/tc39/proposal-observable var $ = require('../internals/export'); +var global = require('../internals/global'); +var call = require('../internals/function-call'); var DESCRIPTORS = require('../internals/descriptors'); var setSpecies = require('../internals/set-species'); -var aFunction = require('../internals/a-function'); +var aCallable = require('../internals/a-callable'); +var isCallable = require('../internals/is-callable'); +var isConstructor = require('../internals/is-constructor'); var anObject = require('../internals/an-object'); var isObject = require('../internals/is-object'); var anInstance = require('../internals/an-instance'); var defineProperty = require('../internals/object-define-property').f; -var createNonEnumerableProperty = require('../internals/create-non-enumerable-property'); +var redefine = require('../internals/redefine'); var redefineAll = require('../internals/redefine-all'); var getIterator = require('../internals/get-iterator'); +var getMethod = require('../internals/get-method'); var iterate = require('../internals/iterate'); var hostReportErrors = require('../internals/host-report-errors'); var wellKnownSymbol = require('../internals/well-known-symbol'); @@ -19,10 +24,7 @@ var InternalStateModule = require('../internals/internal-state'); var OBSERVABLE = wellKnownSymbol('observable'); var getInternalState = InternalStateModule.get; var setInternalState = InternalStateModule.set; - -var getMethod = function (fn) { - return fn == null ? undefined : aFunction(fn); -}; +var Array = global.Array; var cleanupSubscription = function (subscriptionState) { var cleanup = subscriptionState.cleanup; @@ -40,7 +42,8 @@ var subscriptionClosed = function (subscriptionState) { return subscriptionState.observer === undefined; }; -var close = function (subscription, subscriptionState) { +var close = function (subscriptionState) { + var subscription = subscriptionState.facade; if (!DESCRIPTORS) { subscription.closed = true; var subscriptionObserver = subscriptionState.subscriptionObserver; @@ -57,7 +60,7 @@ var Subscription = function (observer, subscriber) { var start; if (!DESCRIPTORS) this.closed = false; try { - if (start = getMethod(observer.start)) start.call(observer, this); + if (start = getMethod(observer, 'start')) call(start, observer, this); } catch (error) { hostReportErrors(error); } @@ -66,9 +69,9 @@ var Subscription = function (observer, subscriber) { try { var cleanup = subscriber(subscriptionObserver); var subscription = cleanup; - if (cleanup != null) subscriptionState.cleanup = typeof cleanup.unsubscribe === 'function' + if (cleanup != null) subscriptionState.cleanup = isCallable(cleanup.unsubscribe) ? function () { subscription.unsubscribe(); } - : aFunction(cleanup); + : aCallable(cleanup); } catch (error) { subscriptionObserver.error(error); return; @@ -79,7 +82,7 @@ Subscription.prototype = redefineAll({}, { unsubscribe: function unsubscribe() { var subscriptionState = getInternalState(this); if (!subscriptionClosed(subscriptionState)) { - close(this, subscriptionState); + close(subscriptionState); cleanupSubscription(subscriptionState); } } @@ -103,22 +106,21 @@ SubscriptionObserver.prototype = redefineAll({}, { if (!subscriptionClosed(subscriptionState)) { var observer = subscriptionState.observer; try { - var nextMethod = getMethod(observer.next); - if (nextMethod) nextMethod.call(observer, value); + var nextMethod = getMethod(observer, 'next'); + if (nextMethod) call(nextMethod, observer, value); } catch (error) { hostReportErrors(error); } } }, error: function error(value) { - var subscription = getInternalState(this).subscription; - var subscriptionState = getInternalState(subscription); + var subscriptionState = getInternalState(getInternalState(this).subscription); if (!subscriptionClosed(subscriptionState)) { var observer = subscriptionState.observer; - close(subscription, subscriptionState); + close(subscriptionState); try { - var errorMethod = getMethod(observer.error); - if (errorMethod) errorMethod.call(observer, value); + var errorMethod = getMethod(observer, 'error'); + if (errorMethod) call(errorMethod, observer, value); else hostReportErrors(value); } catch (err) { hostReportErrors(err); @@ -126,14 +128,13 @@ SubscriptionObserver.prototype = redefineAll({}, { } }, complete: function complete() { - var subscription = getInternalState(this).subscription; - var subscriptionState = getInternalState(subscription); + var subscriptionState = getInternalState(getInternalState(this).subscription); if (!subscriptionClosed(subscriptionState)) { var observer = subscriptionState.observer; - close(subscription, subscriptionState); + close(subscriptionState); try { - var completeMethod = getMethod(observer.complete); - if (completeMethod) completeMethod.call(observer); + var completeMethod = getMethod(observer, 'complete'); + if (completeMethod) call(completeMethod, observer); } catch (error) { hostReportErrors(error); } cleanupSubscription(subscriptionState); @@ -149,14 +150,16 @@ if (DESCRIPTORS) defineProperty(SubscriptionObserver.prototype, 'closed', { }); var $Observable = function Observable(subscriber) { - anInstance(this, $Observable, 'Observable'); - setInternalState(this, { subscriber: aFunction(subscriber) }); + anInstance(this, ObservablePrototype); + setInternalState(this, { subscriber: aCallable(subscriber) }); }; -redefineAll($Observable.prototype, { +var ObservablePrototype = $Observable.prototype; + +redefineAll(ObservablePrototype, { subscribe: function subscribe(observer) { var length = arguments.length; - return new Subscription(typeof observer === 'function' ? { + return new Subscription(isCallable(observer) ? { next: observer, error: length > 1 ? arguments[1] : undefined, complete: length > 2 ? arguments[2] : undefined @@ -166,10 +169,10 @@ redefineAll($Observable.prototype, { redefineAll($Observable, { from: function from(x) { - var C = typeof this === 'function' ? this : $Observable; - var observableMethod = getMethod(anObject(x)[OBSERVABLE]); + var C = isConstructor(this) ? this : $Observable; + var observableMethod = getMethod(anObject(x), OBSERVABLE); if (observableMethod) { - var observable = anObject(observableMethod.call(x)); + var observable = anObject(call(observableMethod, x)); return observable.constructor === C ? observable : new C(function (observer) { return observable.subscribe(observer); }); @@ -184,9 +187,9 @@ redefineAll($Observable, { }); }, of: function of() { - var C = typeof this === 'function' ? this : $Observable; + var C = isConstructor(this) ? this : $Observable; var length = arguments.length; - var items = new Array(length); + var items = Array(length); var index = 0; while (index < length) items[index] = arguments[index++]; return new C(function (observer) { @@ -198,7 +201,7 @@ redefineAll($Observable, { } }); -createNonEnumerableProperty($Observable.prototype, OBSERVABLE, function () { return this; }); +redefine(ObservablePrototype, OBSERVABLE, function () { return this; }); $({ global: true }, { Observable: $Observable