diff options
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom')
12 files changed, 0 insertions, 973 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/AjaxObservable.d.ts b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/AjaxObservable.d.ts deleted file mode 100644 index a88eda73..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/AjaxObservable.d.ts +++ /dev/null @@ -1,151 +0,0 @@ -import { Observable } from '../../Observable'; -import { Subscriber } from '../../Subscriber'; -import { TeardownLogic } from '../../types'; -export interface AjaxRequest { - url?: string; - body?: any; - user?: string; - async?: boolean; - method?: string; - headers?: Object; - timeout?: number; - password?: string; - hasContent?: boolean; - crossDomain?: boolean; - withCredentials?: boolean; - createXHR?: () => XMLHttpRequest; - progressSubscriber?: Subscriber<any>; - responseType?: string; -} -export interface AjaxCreationMethod { - (urlOrRequest: string | AjaxRequest): Observable<AjaxResponse>; - get(url: string, headers?: Object): Observable<AjaxResponse>; - post(url: string, body?: any, headers?: Object): Observable<AjaxResponse>; - put(url: string, body?: any, headers?: Object): Observable<AjaxResponse>; - patch(url: string, body?: any, headers?: Object): Observable<AjaxResponse>; - delete(url: string, headers?: Object): Observable<AjaxResponse>; - getJSON<T>(url: string, headers?: Object): Observable<T>; -} -export declare function ajaxGet(url: string, headers?: Object): AjaxObservable<AjaxResponse>; -export declare function ajaxPost(url: string, body?: any, headers?: Object): Observable<AjaxResponse>; -export declare function ajaxDelete(url: string, headers?: Object): Observable<AjaxResponse>; -export declare function ajaxPut(url: string, body?: any, headers?: Object): Observable<AjaxResponse>; -export declare function ajaxPatch(url: string, body?: any, headers?: Object): Observable<AjaxResponse>; -export declare function ajaxGetJSON<T>(url: string, headers?: Object): Observable<T>; -/** - * We need this JSDoc comment for affecting ESDoc. - * @extends {Ignored} - * @hide true - */ -export declare class AjaxObservable<T> extends Observable<T> { - /** - * Creates an observable for an Ajax request with either a request object with - * url, headers, etc or a string for a URL. - * - * ## Example - * ```ts - * import { ajax } from 'rxjs/ajax'; - * - * const source1 = ajax('/products'); - * const source2 = ajax({ url: 'products', method: 'GET' }); - * ``` - * - * @param {string|Object} request Can be one of the following: - * A string of the URL to make the Ajax call. - * An object with the following properties - * - url: URL of the request - * - body: The body of the request - * - method: Method of the request, such as GET, POST, PUT, PATCH, DELETE - * - async: Whether the request is async - * - headers: Optional headers - * - crossDomain: true if a cross domain request, else false - * - createXHR: a function to override if you need to use an alternate - * XMLHttpRequest implementation. - * - resultSelector: a function to use to alter the output value type of - * the Observable. Gets {@link AjaxResponse} as an argument. - * @return {Observable} An observable sequence containing the XMLHttpRequest. - * @static true - * @name ajax - * @owner Observable - * @nocollapse - */ - static create: AjaxCreationMethod; - private request; - constructor(urlOrRequest: string | AjaxRequest); - /** @deprecated This is an internal implementation detail, do not use. */ - _subscribe(subscriber: Subscriber<T>): TeardownLogic; -} -/** - * We need this JSDoc comment for affecting ESDoc. - * @ignore - * @extends {Ignored} - */ -export declare class AjaxSubscriber<T> extends Subscriber<Event> { - request: AjaxRequest; - private xhr; - private done; - constructor(destination: Subscriber<T>, request: AjaxRequest); - next(e: Event): void; - private send; - private serializeBody; - private setHeaders; - private getHeader; - private setupEvents; - unsubscribe(): void; -} -/** - * A normalized AJAX response. - * - * @see {@link ajax} - * - * @class AjaxResponse - */ -export declare class AjaxResponse { - originalEvent: Event; - xhr: XMLHttpRequest; - request: AjaxRequest; - /** @type {number} The HTTP status code */ - status: number; - /** @type {string|ArrayBuffer|Document|object|any} The response data */ - response: any; - /** @type {string} The raw responseText */ - responseText: string; - /** @type {string} The responseType (e.g. 'json', 'arraybuffer', or 'xml') */ - responseType: string; - constructor(originalEvent: Event, xhr: XMLHttpRequest, request: AjaxRequest); -} -export declare type AjaxErrorNames = 'AjaxError' | 'AjaxTimeoutError'; -/** - * A normalized AJAX error. - * - * @see {@link ajax} - * - * @class AjaxError - */ -export interface AjaxError extends Error { - /** @type {XMLHttpRequest} The XHR instance associated with the error */ - xhr: XMLHttpRequest; - /** @type {AjaxRequest} The AjaxRequest associated with the error */ - request: AjaxRequest; - /** @type {number} The HTTP status code */ - status: number; - /** @type {string} The responseType (e.g. 'json', 'arraybuffer', or 'xml') */ - responseType: string; - /** @type {string|ArrayBuffer|Document|object|any} The response data */ - response: any; -} -export interface AjaxErrorCtor { - new (message: string, xhr: XMLHttpRequest, request: AjaxRequest): AjaxError; -} -export declare const AjaxError: AjaxErrorCtor; -export interface AjaxTimeoutError extends AjaxError { -} -export interface AjaxTimeoutErrorCtor { - new (xhr: XMLHttpRequest, request: AjaxRequest): AjaxTimeoutError; -} -/** - * @see {@link ajax} - * - * @class AjaxTimeoutError - */ -export declare const AjaxTimeoutError: AjaxTimeoutErrorCtor; diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/AjaxObservable.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/AjaxObservable.js deleted file mode 100644 index 432d777a..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/AjaxObservable.js +++ /dev/null @@ -1,391 +0,0 @@ -"use strict"; -var __extends = (this && this.__extends) || (function () { - var extendStatics = function (d, b) { - extendStatics = Object.setPrototypeOf || - ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) || - function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; }; - return extendStatics(d, b); - } - return function (d, b) { - extendStatics(d, b); - function __() { this.constructor = d; } - d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); - }; -})(); -Object.defineProperty(exports, "__esModule", { value: true }); -var root_1 = require("../../util/root"); -var Observable_1 = require("../../Observable"); -var Subscriber_1 = require("../../Subscriber"); -var map_1 = require("../../operators/map"); -function getCORSRequest() { - if (root_1.root.XMLHttpRequest) { - return new root_1.root.XMLHttpRequest(); - } - else if (!!root_1.root.XDomainRequest) { - return new root_1.root.XDomainRequest(); - } - else { - throw new Error('CORS is not supported by your browser'); - } -} -function getXMLHttpRequest() { - if (root_1.root.XMLHttpRequest) { - return new root_1.root.XMLHttpRequest(); - } - else { - var progId = void 0; - try { - var progIds = ['Msxml2.XMLHTTP', 'Microsoft.XMLHTTP', 'Msxml2.XMLHTTP.4.0']; - for (var i = 0; i < 3; i++) { - try { - progId = progIds[i]; - if (new root_1.root.ActiveXObject(progId)) { - break; - } - } - catch (e) { - } - } - return new root_1.root.ActiveXObject(progId); - } - catch (e) { - throw new Error('XMLHttpRequest is not supported by your browser'); - } - } -} -function ajaxGet(url, headers) { - if (headers === void 0) { headers = null; } - return new AjaxObservable({ method: 'GET', url: url, headers: headers }); -} -exports.ajaxGet = ajaxGet; -function ajaxPost(url, body, headers) { - return new AjaxObservable({ method: 'POST', url: url, body: body, headers: headers }); -} -exports.ajaxPost = ajaxPost; -function ajaxDelete(url, headers) { - return new AjaxObservable({ method: 'DELETE', url: url, headers: headers }); -} -exports.ajaxDelete = ajaxDelete; -function ajaxPut(url, body, headers) { - return new AjaxObservable({ method: 'PUT', url: url, body: body, headers: headers }); -} -exports.ajaxPut = ajaxPut; -function ajaxPatch(url, body, headers) { - return new AjaxObservable({ method: 'PATCH', url: url, body: body, headers: headers }); -} -exports.ajaxPatch = ajaxPatch; -var mapResponse = map_1.map(function (x, index) { return x.response; }); -function ajaxGetJSON(url, headers) { - return mapResponse(new AjaxObservable({ - method: 'GET', - url: url, - responseType: 'json', - headers: headers - })); -} -exports.ajaxGetJSON = ajaxGetJSON; -var AjaxObservable = (function (_super) { - __extends(AjaxObservable, _super); - function AjaxObservable(urlOrRequest) { - var _this = _super.call(this) || this; - var request = { - async: true, - createXHR: function () { - return this.crossDomain ? getCORSRequest() : getXMLHttpRequest(); - }, - crossDomain: true, - withCredentials: false, - headers: {}, - method: 'GET', - responseType: 'json', - timeout: 0 - }; - if (typeof urlOrRequest === 'string') { - request.url = urlOrRequest; - } - else { - for (var prop in urlOrRequest) { - if (urlOrRequest.hasOwnProperty(prop)) { - request[prop] = urlOrRequest[prop]; - } - } - } - _this.request = request; - return _this; - } - AjaxObservable.prototype._subscribe = function (subscriber) { - return new AjaxSubscriber(subscriber, this.request); - }; - AjaxObservable.create = (function () { - var create = function (urlOrRequest) { - return new AjaxObservable(urlOrRequest); - }; - create.get = ajaxGet; - create.post = ajaxPost; - create.delete = ajaxDelete; - create.put = ajaxPut; - create.patch = ajaxPatch; - create.getJSON = ajaxGetJSON; - return create; - })(); - return AjaxObservable; -}(Observable_1.Observable)); -exports.AjaxObservable = AjaxObservable; -var AjaxSubscriber = (function (_super) { - __extends(AjaxSubscriber, _super); - function AjaxSubscriber(destination, request) { - var _this = _super.call(this, destination) || this; - _this.request = request; - _this.done = false; - var headers = request.headers = request.headers || {}; - if (!request.crossDomain && !_this.getHeader(headers, 'X-Requested-With')) { - headers['X-Requested-With'] = 'XMLHttpRequest'; - } - var contentTypeHeader = _this.getHeader(headers, 'Content-Type'); - if (!contentTypeHeader && !(root_1.root.FormData && request.body instanceof root_1.root.FormData) && typeof request.body !== 'undefined') { - headers['Content-Type'] = 'application/x-www-form-urlencoded; charset=UTF-8'; - } - request.body = _this.serializeBody(request.body, _this.getHeader(request.headers, 'Content-Type')); - _this.send(); - return _this; - } - AjaxSubscriber.prototype.next = function (e) { - this.done = true; - var _a = this, xhr = _a.xhr, request = _a.request, destination = _a.destination; - var result; - try { - result = new AjaxResponse(e, xhr, request); - } - catch (err) { - return destination.error(err); - } - destination.next(result); - }; - AjaxSubscriber.prototype.send = function () { - var _a = this, request = _a.request, _b = _a.request, user = _b.user, method = _b.method, url = _b.url, async = _b.async, password = _b.password, headers = _b.headers, body = _b.body; - try { - var xhr = this.xhr = request.createXHR(); - this.setupEvents(xhr, request); - if (user) { - xhr.open(method, url, async, user, password); - } - else { - xhr.open(method, url, async); - } - if (async) { - xhr.timeout = request.timeout; - xhr.responseType = request.responseType; - } - if ('withCredentials' in xhr) { - xhr.withCredentials = !!request.withCredentials; - } - this.setHeaders(xhr, headers); - if (body) { - xhr.send(body); - } - else { - xhr.send(); - } - } - catch (err) { - this.error(err); - } - }; - AjaxSubscriber.prototype.serializeBody = function (body, contentType) { - if (!body || typeof body === 'string') { - return body; - } - else if (root_1.root.FormData && body instanceof root_1.root.FormData) { - return body; - } - if (contentType) { - var splitIndex = contentType.indexOf(';'); - if (splitIndex !== -1) { - contentType = contentType.substring(0, splitIndex); - } - } - switch (contentType) { - case 'application/x-www-form-urlencoded': - return Object.keys(body).map(function (key) { return encodeURIComponent(key) + "=" + encodeURIComponent(body[key]); }).join('&'); - case 'application/json': - return JSON.stringify(body); - default: - return body; - } - }; - AjaxSubscriber.prototype.setHeaders = function (xhr, headers) { - for (var key in headers) { - if (headers.hasOwnProperty(key)) { - xhr.setRequestHeader(key, headers[key]); - } - } - }; - AjaxSubscriber.prototype.getHeader = function (headers, headerName) { - for (var key in headers) { - if (key.toLowerCase() === headerName.toLowerCase()) { - return headers[key]; - } - } - return undefined; - }; - AjaxSubscriber.prototype.setupEvents = function (xhr, request) { - var progressSubscriber = request.progressSubscriber; - function xhrTimeout(e) { - var _a = xhrTimeout, subscriber = _a.subscriber, progressSubscriber = _a.progressSubscriber, request = _a.request; - if (progressSubscriber) { - progressSubscriber.error(e); - } - var error; - try { - error = new exports.AjaxTimeoutError(this, request); - } - catch (err) { - error = err; - } - subscriber.error(error); - } - xhr.ontimeout = xhrTimeout; - xhrTimeout.request = request; - xhrTimeout.subscriber = this; - xhrTimeout.progressSubscriber = progressSubscriber; - if (xhr.upload && 'withCredentials' in xhr) { - if (progressSubscriber) { - var xhrProgress_1; - xhrProgress_1 = function (e) { - var progressSubscriber = xhrProgress_1.progressSubscriber; - progressSubscriber.next(e); - }; - if (root_1.root.XDomainRequest) { - xhr.onprogress = xhrProgress_1; - } - else { - xhr.upload.onprogress = xhrProgress_1; - } - xhrProgress_1.progressSubscriber = progressSubscriber; - } - var xhrError_1; - xhrError_1 = function (e) { - var _a = xhrError_1, progressSubscriber = _a.progressSubscriber, subscriber = _a.subscriber, request = _a.request; - if (progressSubscriber) { - progressSubscriber.error(e); - } - var error; - try { - error = new exports.AjaxError('ajax error', this, request); - } - catch (err) { - error = err; - } - subscriber.error(error); - }; - xhr.onerror = xhrError_1; - xhrError_1.request = request; - xhrError_1.subscriber = this; - xhrError_1.progressSubscriber = progressSubscriber; - } - function xhrReadyStateChange(e) { - return; - } - xhr.onreadystatechange = xhrReadyStateChange; - xhrReadyStateChange.subscriber = this; - xhrReadyStateChange.progressSubscriber = progressSubscriber; - xhrReadyStateChange.request = request; - function xhrLoad(e) { - var _a = xhrLoad, subscriber = _a.subscriber, progressSubscriber = _a.progressSubscriber, request = _a.request; - if (this.readyState === 4) { - var status_1 = this.status === 1223 ? 204 : this.status; - var response = (this.responseType === 'text' ? (this.response || this.responseText) : this.response); - if (status_1 === 0) { - status_1 = response ? 200 : 0; - } - if (status_1 < 400) { - if (progressSubscriber) { - progressSubscriber.complete(); - } - subscriber.next(e); - subscriber.complete(); - } - else { - if (progressSubscriber) { - progressSubscriber.error(e); - } - var error = void 0; - try { - error = new exports.AjaxError('ajax error ' + status_1, this, request); - } - catch (err) { - error = err; - } - subscriber.error(error); - } - } - } - xhr.onload = xhrLoad; - xhrLoad.subscriber = this; - xhrLoad.progressSubscriber = progressSubscriber; - xhrLoad.request = request; - }; - AjaxSubscriber.prototype.unsubscribe = function () { - var _a = this, done = _a.done, xhr = _a.xhr; - if (!done && xhr && xhr.readyState !== 4 && typeof xhr.abort === 'function') { - xhr.abort(); - } - _super.prototype.unsubscribe.call(this); - }; - return AjaxSubscriber; -}(Subscriber_1.Subscriber)); -exports.AjaxSubscriber = AjaxSubscriber; -var AjaxResponse = (function () { - function AjaxResponse(originalEvent, xhr, request) { - this.originalEvent = originalEvent; - this.xhr = xhr; - this.request = request; - this.status = xhr.status; - this.responseType = xhr.responseType || request.responseType; - this.response = parseXhrResponse(this.responseType, xhr); - } - return AjaxResponse; -}()); -exports.AjaxResponse = AjaxResponse; -var AjaxErrorImpl = (function () { - function AjaxErrorImpl(message, xhr, request) { - Error.call(this); - this.message = message; - this.name = 'AjaxError'; - this.xhr = xhr; - this.request = request; - this.status = xhr.status; - this.responseType = xhr.responseType || request.responseType; - this.response = parseXhrResponse(this.responseType, xhr); - return this; - } - AjaxErrorImpl.prototype = Object.create(Error.prototype); - return AjaxErrorImpl; -})(); -exports.AjaxError = AjaxErrorImpl; -function parseJson(xhr) { - if ('response' in xhr) { - return xhr.responseType ? xhr.response : JSON.parse(xhr.response || xhr.responseText || 'null'); - } - else { - return JSON.parse(xhr.responseText || 'null'); - } -} -function parseXhrResponse(responseType, xhr) { - switch (responseType) { - case 'json': - return parseJson(xhr); - case 'xml': - return xhr.responseXML; - case 'text': - default: - return ('response' in xhr) ? xhr.response : xhr.responseText; - } -} -function AjaxTimeoutErrorImpl(xhr, request) { - exports.AjaxError.call(this, 'ajax timeout', xhr, request); - this.name = 'AjaxTimeoutError'; - return this; -} -exports.AjaxTimeoutError = AjaxTimeoutErrorImpl; -//# sourceMappingURL=AjaxObservable.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/AjaxObservable.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/AjaxObservable.js.map deleted file mode 100644 index 3c5a93e3..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/AjaxObservable.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"AjaxObservable.js","sources":["../../../src/internal/observable/dom/AjaxObservable.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;AAAA,wCAAuC;AACvC,+CAA8C;AAC9C,+CAA8C;AAE9C,2CAA0C;AAmB1C,SAAS,cAAc;IACrB,IAAI,WAAI,CAAC,cAAc,EAAE;QACvB,OAAO,IAAI,WAAI,CAAC,cAAc,EAAE,CAAC;KAClC;SAAM,IAAI,CAAC,CAAC,WAAI,CAAC,cAAc,EAAE;QAChC,OAAO,IAAI,WAAI,CAAC,cAAc,EAAE,CAAC;KAClC;SAAM;QACL,MAAM,IAAI,KAAK,CAAC,uCAAuC,CAAC,CAAC;KAC1D;AACH,CAAC;AAED,SAAS,iBAAiB;IACxB,IAAI,WAAI,CAAC,cAAc,EAAE;QACvB,OAAO,IAAI,WAAI,CAAC,cAAc,EAAE,CAAC;KAClC;SAAM;QACL,IAAI,MAAM,SAAQ,CAAC;QACnB,IAAI;YACF,IAAM,OAAO,GAAG,CAAC,gBAAgB,EAAE,mBAAmB,EAAE,oBAAoB,CAAC,CAAC;YAC9E,KAAK,IAAI,CAAC,GAAG,CAAC,EAAE,CAAC,GAAG,CAAC,EAAE,CAAC,EAAE,EAAE;gBAC1B,IAAI;oBACF,MAAM,GAAG,OAAO,CAAC,CAAC,CAAC,CAAC;oBACpB,IAAI,IAAI,WAAI,CAAC,aAAa,CAAC,MAAM,CAAC,EAAE;wBAClC,MAAM;qBACP;iBACF;gBAAC,OAAO,CAAC,EAAE;iBAEX;aACF;YACD,OAAO,IAAI,WAAI,CAAC,aAAa,CAAC,MAAM,CAAC,CAAC;SACvC;QAAC,OAAO,CAAC,EAAE;YACV,MAAM,IAAI,KAAK,CAAC,iDAAiD,CAAC,CAAC;SACpE;KACF;AACH,CAAC;AAYD,SAAgB,OAAO,CAAC,GAAW,EAAE,OAAsB;IAAtB,wBAAA,EAAA,cAAsB;IACzD,OAAO,IAAI,cAAc,CAAe,EAAE,MAAM,EAAE,KAAK,EAAE,GAAG,KAAA,EAAE,OAAO,SAAA,EAAE,CAAC,CAAC;AAC3E,CAAC;AAFD,0BAEC;AAED,SAAgB,QAAQ,CAAC,GAAW,EAAE,IAAU,EAAE,OAAgB;IAChE,OAAO,IAAI,cAAc,CAAe,EAAE,MAAM,EAAE,MAAM,EAAE,GAAG,KAAA,EAAE,IAAI,MAAA,EAAE,OAAO,SAAA,EAAE,CAAC,CAAC;AAClF,CAAC;AAFD,4BAEC;AAED,SAAgB,UAAU,CAAC,GAAW,EAAE,OAAgB;IACtD,OAAO,IAAI,cAAc,CAAe,EAAE,MAAM,EAAE,QAAQ,EAAE,GAAG,KAAA,EAAE,OAAO,SAAA,EAAE,CAAC,CAAC;AAC9E,CAAC;AAFD,gCAEC;AAED,SAAgB,OAAO,CAAC,GAAW,EAAE,IAAU,EAAE,OAAgB;IAC/D,OAAO,IAAI,cAAc,CAAe,EAAE,MAAM,EAAE,KAAK,EAAE,GAAG,KAAA,EAAE,IAAI,MAAA,EAAE,OAAO,SAAA,EAAE,CAAC,CAAC;AACjF,CAAC;AAFD,0BAEC;AAED,SAAgB,SAAS,CAAC,GAAW,EAAE,IAAU,EAAE,OAAgB;IACjE,OAAO,IAAI,cAAc,CAAe,EAAE,MAAM,EAAE,OAAO,EAAE,GAAG,KAAA,EAAE,IAAI,MAAA,EAAE,OAAO,SAAA,EAAE,CAAC,CAAC;AACnF,CAAC;AAFD,8BAEC;AAED,IAAM,WAAW,GAAG,SAAG,CAAC,UAAC,CAAe,EAAE,KAAa,IAAK,OAAA,CAAC,CAAC,QAAQ,EAAV,CAAU,CAAC,CAAC;AAExE,SAAgB,WAAW,CAAI,GAAW,EAAE,OAAgB;IAC1D,OAAO,WAAW,CAChB,IAAI,cAAc,CAAe;QAC/B,MAAM,EAAE,KAAK;QACb,GAAG,KAAA;QACH,YAAY,EAAE,MAAM;QACpB,OAAO,SAAA;KACR,CAAC,CACH,CAAC;AACJ,CAAC;AATD,kCASC;AAOD;IAAuC,kCAAa;IAiDlD,wBAAY,YAAkC;QAA9C,YACE,iBAAO,SA0BR;QAxBC,IAAM,OAAO,GAAgB;YAC3B,KAAK,EAAE,IAAI;YACX,SAAS,EAAE;gBACT,OAAO,IAAI,CAAC,WAAW,CAAC,CAAC,CAAC,cAAc,EAAE,CAAC,CAAC,CAAC,iBAAiB,EAAE,CAAC;YACnE,CAAC;YACD,WAAW,EAAE,IAAI;YACjB,eAAe,EAAE,KAAK;YACtB,OAAO,EAAE,EAAE;YACX,MAAM,EAAE,KAAK;YACb,YAAY,EAAE,MAAM;YACpB,OAAO,EAAE,CAAC;SACX,CAAC;QAEF,IAAI,OAAO,YAAY,KAAK,QAAQ,EAAE;YACpC,OAAO,CAAC,GAAG,GAAG,YAAY,CAAC;SAC5B;aAAM;YACL,KAAK,IAAM,IAAI,IAAI,YAAY,EAAE;gBAC/B,IAAI,YAAY,CAAC,cAAc,CAAC,IAAI,CAAC,EAAE;oBACrC,OAAO,CAAC,IAAI,CAAC,GAAG,YAAY,CAAC,IAAI,CAAC,CAAC;iBACpC;aACF;SACF;QAED,KAAI,CAAC,OAAO,GAAG,OAAO,CAAC;;IACzB,CAAC;IAGD,mCAAU,GAAV,UAAW,UAAyB;QAClC,OAAO,IAAI,cAAc,CAAC,UAAU,EAAE,IAAI,CAAC,OAAO,CAAC,CAAC;IACtD,CAAC;IAjDM,qBAAM,GAAuB,CAAC;QACnC,IAAM,MAAM,GAAQ,UAAC,YAAkC;YACrD,OAAO,IAAI,cAAc,CAAC,YAAY,CAAC,CAAC;QAC1C,CAAC,CAAC;QAEF,MAAM,CAAC,GAAG,GAAG,OAAO,CAAC;QACrB,MAAM,CAAC,IAAI,GAAG,QAAQ,CAAC;QACvB,MAAM,CAAC,MAAM,GAAG,UAAU,CAAC;QAC3B,MAAM,CAAC,GAAG,GAAG,OAAO,CAAC;QACrB,MAAM,CAAC,KAAK,GAAG,SAAS,CAAC;QACzB,MAAM,CAAC,OAAO,GAAG,WAAW,CAAC;QAE7B,OAA2B,MAAM,CAAC;IACpC,CAAC,CAAC,EAAE,CAAC;IAqCP,qBAAC;CAAA,AAlFD,CAAuC,uBAAU,GAkFhD;AAlFY,wCAAc;AAyF3B;IAAuC,kCAAiB;IAItD,wBAAY,WAA0B,EAAS,OAAoB;QAAnE,YACE,kBAAM,WAAW,CAAC,SAmBnB;QApB8C,aAAO,GAAP,OAAO,CAAa;QAF3D,UAAI,GAAY,KAAK,CAAC;QAK5B,IAAM,OAAO,GAAG,OAAO,CAAC,OAAO,GAAG,OAAO,CAAC,OAAO,IAAI,EAAE,CAAC;QAGxD,IAAI,CAAC,OAAO,CAAC,WAAW,IAAI,CAAC,KAAI,CAAC,SAAS,CAAC,OAAO,EAAE,kBAAkB,CAAC,EAAE;YACxE,OAAO,CAAC,kBAAkB,CAAC,GAAG,gBAAgB,CAAC;SAChD;QAGD,IAAI,iBAAiB,GAAG,KAAI,CAAC,SAAS,CAAC,OAAO,EAAE,cAAc,CAAC,CAAC;QAChE,IAAI,CAAC,iBAAiB,IAAI,CAAC,CAAC,WAAI,CAAC,QAAQ,IAAI,OAAO,CAAC,IAAI,YAAY,WAAI,CAAC,QAAQ,CAAC,IAAI,OAAO,OAAO,CAAC,IAAI,KAAK,WAAW,EAAE;YAC1H,OAAO,CAAC,cAAc,CAAC,GAAG,kDAAkD,CAAC;SAC9E;QAGD,OAAO,CAAC,IAAI,GAAG,KAAI,CAAC,aAAa,CAAC,OAAO,CAAC,IAAI,EAAE,KAAI,CAAC,SAAS,CAAC,OAAO,CAAC,OAAO,EAAE,cAAc,CAAC,CAAC,CAAC;QAEjG,KAAI,CAAC,IAAI,EAAE,CAAC;;IACd,CAAC;IAED,6BAAI,GAAJ,UAAK,CAAQ;QACX,IAAI,CAAC,IAAI,GAAG,IAAI,CAAC;QACX,IAAA,SAAoC,EAAlC,YAAG,EAAE,oBAAO,EAAE,4BAAW,CAAU;QAC3C,IAAI,MAAM,CAAC;QACX,IAAI;YACF,MAAM,GAAG,IAAI,YAAY,CAAC,CAAC,EAAE,GAAG,EAAE,OAAO,CAAC,CAAC;SAC5C;QAAC,OAAO,GAAG,EAAE;YACZ,OAAO,WAAW,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;SAC/B;QACD,WAAW,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC;IAC3B,CAAC;IAEO,6BAAI,GAAZ;QACQ,IAAA,SAGE,EAFN,oBAAO,EACP,eAA8D,EAAnD,cAAI,EAAE,kBAAM,EAAE,YAAG,EAAE,gBAAK,EAAE,sBAAQ,EAAE,oBAAO,EAAE,cAAI,CACrD;QACT,IAAI;YACF,IAAM,GAAG,GAAG,IAAI,CAAC,GAAG,GAAG,OAAO,CAAC,SAAS,EAAE,CAAC;YAM3C,IAAI,CAAC,WAAW,CAAC,GAAG,EAAE,OAAO,CAAC,CAAC;YAE/B,IAAI,IAAI,EAAE;gBACR,GAAG,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,EAAE,KAAK,EAAE,IAAI,EAAE,QAAQ,CAAC,CAAC;aAC9C;iBAAM;gBACL,GAAG,CAAC,IAAI,CAAC,MAAM,EAAE,GAAG,EAAE,KAAK,CAAC,CAAC;aAC9B;YAGD,IAAI,KAAK,EAAE;gBACT,GAAG,CAAC,OAAO,GAAG,OAAO,CAAC,OAAO,CAAC;gBAC9B,GAAG,CAAC,YAAY,GAAG,OAAO,CAAC,YAAmB,CAAC;aAChD;YAED,IAAI,iBAAiB,IAAI,GAAG,EAAE;gBAC5B,GAAG,CAAC,eAAe,GAAG,CAAC,CAAC,OAAO,CAAC,eAAe,CAAC;aACjD;YAGD,IAAI,CAAC,UAAU,CAAC,GAAG,EAAE,OAAO,CAAC,CAAC;YAG9B,IAAI,IAAI,EAAE;gBACR,GAAG,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAChB;iBAAM;gBACL,GAAG,CAAC,IAAI,EAAE,CAAC;aACZ;SACF;QAAC,OAAO,GAAG,EAAE;YACZ,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;SACjB;IACH,CAAC;IAEO,sCAAa,GAArB,UAAsB,IAAS,EAAE,WAAoB;QACnD,IAAI,CAAC,IAAI,IAAI,OAAO,IAAI,KAAK,QAAQ,EAAE;YACrC,OAAO,IAAI,CAAC;SACb;aAAM,IAAI,WAAI,CAAC,QAAQ,IAAI,IAAI,YAAY,WAAI,CAAC,QAAQ,EAAE;YACzD,OAAO,IAAI,CAAC;SACb;QAED,IAAI,WAAW,EAAE;YACf,IAAM,UAAU,GAAG,WAAW,CAAC,OAAO,CAAC,GAAG,CAAC,CAAC;YAC5C,IAAI,UAAU,KAAK,CAAC,CAAC,EAAE;gBACrB,WAAW,GAAG,WAAW,CAAC,SAAS,CAAC,CAAC,EAAE,UAAU,CAAC,CAAC;aACpD;SACF;QAED,QAAQ,WAAW,EAAE;YACnB,KAAK,mCAAmC;gBACtC,OAAO,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC,GAAG,CAAC,UAAA,GAAG,IAAI,OAAG,kBAAkB,CAAC,GAAG,CAAC,SAAI,kBAAkB,CAAC,IAAI,CAAC,GAAG,CAAC,CAAG,EAA7D,CAA6D,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;YAC/G,KAAK,kBAAkB;gBACrB,OAAO,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,CAAC;YAC9B;gBACE,OAAO,IAAI,CAAC;SACf;IACH,CAAC;IAEO,mCAAU,GAAlB,UAAmB,GAAmB,EAAE,OAAe;QACrD,KAAK,IAAI,GAAG,IAAI,OAAO,EAAE;YACvB,IAAI,OAAO,CAAC,cAAc,CAAC,GAAG,CAAC,EAAE;gBAC/B,GAAG,CAAC,gBAAgB,CAAC,GAAG,EAAE,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC;aACzC;SACF;IACH,CAAC;IAEO,kCAAS,GAAjB,UAAkB,OAAW,EAAE,UAAkB;QAC/C,KAAK,IAAI,GAAG,IAAI,OAAO,EAAE;YACvB,IAAI,GAAG,CAAC,WAAW,EAAE,KAAK,UAAU,CAAC,WAAW,EAAE,EAAE;gBAClD,OAAO,OAAO,CAAC,GAAG,CAAC,CAAC;aACrB;SACF;QAED,OAAO,SAAS,CAAC;IACnB,CAAC;IAEO,oCAAW,GAAnB,UAAoB,GAAmB,EAAE,OAAoB;QAC3D,IAAM,kBAAkB,GAAG,OAAO,CAAC,kBAAkB,CAAC;QAEtD,SAAS,UAAU,CAAuB,CAAgB;YAClD,IAAA,eAA8D,EAA7D,0BAAU,EAAE,0CAAkB,EAAE,oBAAO,CAAuB;YACrE,IAAI,kBAAkB,EAAE;gBACtB,kBAAkB,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;aAC7B;YACD,IAAI,KAAK,CAAC;YACV,IAAI;gBACF,KAAK,GAAG,IAAI,wBAAgB,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC;aAC7C;YAAC,OAAO,GAAG,EAAE;gBACZ,KAAK,GAAG,GAAG,CAAC;aACb;YACD,UAAU,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;QAC1B,CAAC;QACD,GAAG,CAAC,SAAS,GAAG,UAAU,CAAC;QACrB,UAAW,CAAC,OAAO,GAAG,OAAO,CAAC;QAC9B,UAAW,CAAC,UAAU,GAAG,IAAI,CAAC;QAC9B,UAAW,CAAC,kBAAkB,GAAG,kBAAkB,CAAC;QAC1D,IAAI,GAAG,CAAC,MAAM,IAAI,iBAAiB,IAAI,GAAG,EAAE;YAC1C,IAAI,kBAAkB,EAAE;gBACtB,IAAI,aAAuC,CAAC;gBAC5C,aAAW,GAAG,UAAS,CAAgB;oBAC7B,IAAA,qDAAkB,CAAwB;oBAClD,kBAAkB,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;gBAC7B,CAAC,CAAC;gBACF,IAAI,WAAI,CAAC,cAAc,EAAE;oBACvB,GAAG,CAAC,UAAU,GAAG,aAAW,CAAC;iBAC9B;qBAAM;oBACL,GAAG,CAAC,MAAM,CAAC,UAAU,GAAG,aAAW,CAAC;iBACrC;gBACK,aAAY,CAAC,kBAAkB,GAAG,kBAAkB,CAAC;aAC5D;YACD,IAAI,UAA0B,CAAC;YAC/B,UAAQ,GAAG,UAA+B,CAAa;gBAC/C,IAAA,eAA6D,EAA3D,0CAAkB,EAAE,0BAAU,EAAE,oBAAO,CAAqB;gBACpE,IAAI,kBAAkB,EAAE;oBACtB,kBAAkB,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;iBAC7B;gBACD,IAAI,KAAK,CAAC;gBACV,IAAI;oBACF,KAAK,GAAG,IAAI,iBAAS,CAAC,YAAY,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;iBACpD;gBAAC,OAAO,GAAG,EAAE;oBACZ,KAAK,GAAG,GAAG,CAAC;iBACb;gBACD,UAAU,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;YAC1B,CAAC,CAAC;YACF,GAAG,CAAC,OAAO,GAAG,UAAQ,CAAC;YACjB,UAAS,CAAC,OAAO,GAAG,OAAO,CAAC;YAC5B,UAAS,CAAC,UAAU,GAAG,IAAI,CAAC;YAC5B,UAAS,CAAC,kBAAkB,GAAG,kBAAkB,CAAC;SACzD;QAED,SAAS,mBAAmB,CAAuB,CAAQ;YACzD,OAAO;QACT,CAAC;QACD,GAAG,CAAC,kBAAkB,GAAG,mBAAmB,CAAC;QACvC,mBAAoB,CAAC,UAAU,GAAG,IAAI,CAAC;QACvC,mBAAoB,CAAC,kBAAkB,GAAG,kBAAkB,CAAC;QAC7D,mBAAoB,CAAC,OAAO,GAAG,OAAO,CAAC;QAE7C,SAAS,OAAO,CAAuB,CAAQ;YACvC,IAAA,YAA4D,EAA1D,0BAAU,EAAE,0CAAkB,EAAE,oBAAO,CAAoB;YACnE,IAAI,IAAI,CAAC,UAAU,KAAK,CAAC,EAAE;gBAEzB,IAAI,QAAM,GAAW,IAAI,CAAC,MAAM,KAAK,IAAI,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,IAAI,CAAC,MAAM,CAAC;gBAC9D,IAAI,QAAQ,GAAQ,CAAC,IAAI,CAAC,YAAY,KAAK,MAAM,CAAC,CAAC,CAAE,CACnD,IAAI,CAAC,QAAQ,IAAI,IAAI,CAAC,YAAY,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;gBAKvD,IAAI,QAAM,KAAK,CAAC,EAAE;oBAChB,QAAM,GAAG,QAAQ,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,CAAC;iBAC7B;gBAGD,IAAI,QAAM,GAAG,GAAG,EAAE;oBAChB,IAAI,kBAAkB,EAAE;wBACtB,kBAAkB,CAAC,QAAQ,EAAE,CAAC;qBAC/B;oBACD,UAAU,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;oBACnB,UAAU,CAAC,QAAQ,EAAE,CAAC;iBACvB;qBAAM;oBACL,IAAI,kBAAkB,EAAE;wBACtB,kBAAkB,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;qBAC7B;oBACD,IAAI,KAAK,SAAA,CAAC;oBACV,IAAI;wBACF,KAAK,GAAG,IAAI,iBAAS,CAAC,aAAa,GAAG,QAAM,EAAE,IAAI,EAAE,OAAO,CAAC,CAAC;qBAC9D;oBAAC,OAAO,GAAG,EAAE;wBACZ,KAAK,GAAG,GAAG,CAAC;qBACb;oBACD,UAAU,CAAC,KAAK,CAAC,KAAK,CAAC,CAAC;iBACzB;aACF;QACH,CAAC;QACD,GAAG,CAAC,MAAM,GAAG,OAAO,CAAC;QACf,OAAQ,CAAC,UAAU,GAAG,IAAI,CAAC;QAC3B,OAAQ,CAAC,kBAAkB,GAAG,kBAAkB,CAAC;QACjD,OAAQ,CAAC,OAAO,GAAG,OAAO,CAAC;IACnC,CAAC;IAED,oCAAW,GAAX;QACQ,IAAA,SAAoB,EAAlB,cAAI,EAAE,YAAG,CAAU;QAC3B,IAAI,CAAC,IAAI,IAAI,GAAG,IAAI,GAAG,CAAC,UAAU,KAAK,CAAC,IAAI,OAAO,GAAG,CAAC,KAAK,KAAK,UAAU,EAAE;YAC3E,GAAG,CAAC,KAAK,EAAE,CAAC;SACb;QACD,iBAAM,WAAW,WAAE,CAAC;IACtB,CAAC;IACH,qBAAC;AAAD,CAAC,AA3OD,CAAuC,uBAAU,GA2OhD;AA3OY,wCAAc;AAoP3B;IAaE,sBAAmB,aAAoB,EAAS,GAAmB,EAAS,OAAoB;QAA7E,kBAAa,GAAb,aAAa,CAAO;QAAS,QAAG,GAAH,GAAG,CAAgB;QAAS,YAAO,GAAP,OAAO,CAAa;QAC9F,IAAI,CAAC,MAAM,GAAG,GAAG,CAAC,MAAM,CAAC;QACzB,IAAI,CAAC,YAAY,GAAG,GAAG,CAAC,YAAY,IAAI,OAAO,CAAC,YAAY,CAAC;QAC7D,IAAI,CAAC,QAAQ,GAAG,gBAAgB,CAAC,IAAI,CAAC,YAAY,EAAE,GAAG,CAAC,CAAC;IAC3D,CAAC;IACH,mBAAC;AAAD,CAAC,AAlBD,IAkBC;AAlBY,oCAAY;AAkDzB,IAAM,aAAa,GAAG,CAAC;IACrB,SAAS,aAAa,CAAY,OAAe,EAAE,GAAmB,EAAE,OAAoB;QAC1F,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;QACjB,IAAI,CAAC,OAAO,GAAG,OAAO,CAAC;QACvB,IAAI,CAAC,IAAI,GAAG,WAAW,CAAC;QACxB,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC;QACf,IAAI,CAAC,OAAO,GAAG,OAAO,CAAC;QACvB,IAAI,CAAC,MAAM,GAAG,GAAG,CAAC,MAAM,CAAC;QACzB,IAAI,CAAC,YAAY,GAAG,GAAG,CAAC,YAAY,IAAI,OAAO,CAAC,YAAY,CAAC;QAC7D,IAAI,CAAC,QAAQ,GAAG,gBAAgB,CAAC,IAAI,CAAC,YAAY,EAAE,GAAG,CAAC,CAAC;QACzD,OAAO,IAAI,CAAC;IACd,CAAC;IACD,aAAa,CAAC,SAAS,GAAG,MAAM,CAAC,MAAM,CAAC,KAAK,CAAC,SAAS,CAAC,CAAC;IACzD,OAAO,aAAa,CAAC;AACvB,CAAC,CAAC,EAAE,CAAC;AAEQ,QAAA,SAAS,GAAkB,aAAoB,CAAC;AAE7D,SAAS,SAAS,CAAC,GAAmB;IAGpC,IAAI,UAAU,IAAK,GAAW,EAAE;QAE9B,OAAO,GAAG,CAAC,YAAY,CAAC,CAAC,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,CAAC,IAAI,CAAC,KAAK,CAAC,GAAG,CAAC,QAAQ,IAAI,GAAG,CAAC,YAAY,IAAI,MAAM,CAAC,CAAC;KACjG;SAAM;QACL,OAAO,IAAI,CAAC,KAAK,CAAE,GAAW,CAAC,YAAY,IAAI,MAAM,CAAC,CAAC;KACxD;AACH,CAAC;AAED,SAAS,gBAAgB,CAAC,YAAoB,EAAE,GAAmB;IACjE,QAAQ,YAAY,EAAE;QACpB,KAAK,MAAM;YACP,OAAO,SAAS,CAAC,GAAG,CAAC,CAAC;QACxB,KAAK,KAAK;YACR,OAAO,GAAG,CAAC,WAAW,CAAC;QACzB,KAAK,MAAM,CAAC;QACZ;YAGI,OAAQ,CAAC,UAAU,IAAK,GAAW,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC,CAAC,GAAG,CAAC,YAAY,CAAC;KAC9E;AACH,CAAC;AASD,SAAS,oBAAoB,CAAY,GAAmB,EAAE,OAAoB;IAChF,iBAAS,CAAC,IAAI,CAAC,IAAI,EAAE,cAAc,EAAE,GAAG,EAAE,OAAO,CAAC,CAAC;IACnD,IAAI,CAAC,IAAI,GAAG,kBAAkB,CAAC;IAC/B,OAAO,IAAI,CAAC;AACd,CAAC;AAOY,QAAA,gBAAgB,GAAyB,oBAA2B,CAAC"} diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/WebSocketSubject.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/WebSocketSubject.js deleted file mode 100644 index d3edd3c5..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/WebSocketSubject.js +++ /dev/null @@ -1,241 +0,0 @@ -"use strict"; -var __extends = (this && this.__extends) || (function () { - var extendStatics = function (d, b) { - extendStatics = Object.setPrototypeOf || - ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) || - function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; }; - return extendStatics(d, b); - } - return function (d, b) { - extendStatics(d, b); - function __() { this.constructor = d; } - d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __()); - }; -})(); -var __assign = (this && this.__assign) || function () { - __assign = Object.assign || function(t) { - for (var s, i = 1, n = arguments.length; i < n; i++) { - s = arguments[i]; - for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p)) - t[p] = s[p]; - } - return t; - }; - return __assign.apply(this, arguments); -}; -Object.defineProperty(exports, "__esModule", { value: true }); -var Subject_1 = require("../../Subject"); -var Subscriber_1 = require("../../Subscriber"); -var Observable_1 = require("../../Observable"); -var Subscription_1 = require("../../Subscription"); -var ReplaySubject_1 = require("../../ReplaySubject"); -var DEFAULT_WEBSOCKET_CONFIG = { - url: '', - deserializer: function (e) { return JSON.parse(e.data); }, - serializer: function (value) { return JSON.stringify(value); }, -}; -var WEBSOCKETSUBJECT_INVALID_ERROR_OBJECT = 'WebSocketSubject.error must be called with an object with an error code, and an optional reason: { code: number, reason: string }'; -var WebSocketSubject = (function (_super) { - __extends(WebSocketSubject, _super); - function WebSocketSubject(urlConfigOrSource, destination) { - var _this = _super.call(this) || this; - if (urlConfigOrSource instanceof Observable_1.Observable) { - _this.destination = destination; - _this.source = urlConfigOrSource; - } - else { - var config = _this._config = __assign({}, DEFAULT_WEBSOCKET_CONFIG); - _this._output = new Subject_1.Subject(); - if (typeof urlConfigOrSource === 'string') { - config.url = urlConfigOrSource; - } - else { - for (var key in urlConfigOrSource) { - if (urlConfigOrSource.hasOwnProperty(key)) { - config[key] = urlConfigOrSource[key]; - } - } - } - if (!config.WebSocketCtor && WebSocket) { - config.WebSocketCtor = WebSocket; - } - else if (!config.WebSocketCtor) { - throw new Error('no WebSocket constructor can be found'); - } - _this.destination = new ReplaySubject_1.ReplaySubject(); - } - return _this; - } - WebSocketSubject.prototype.lift = function (operator) { - var sock = new WebSocketSubject(this._config, this.destination); - sock.operator = operator; - sock.source = this; - return sock; - }; - WebSocketSubject.prototype._resetState = function () { - this._socket = null; - if (!this.source) { - this.destination = new ReplaySubject_1.ReplaySubject(); - } - this._output = new Subject_1.Subject(); - }; - WebSocketSubject.prototype.multiplex = function (subMsg, unsubMsg, messageFilter) { - var self = this; - return new Observable_1.Observable(function (observer) { - try { - self.next(subMsg()); - } - catch (err) { - observer.error(err); - } - var subscription = self.subscribe(function (x) { - try { - if (messageFilter(x)) { - observer.next(x); - } - } - catch (err) { - observer.error(err); - } - }, function (err) { return observer.error(err); }, function () { return observer.complete(); }); - return function () { - try { - self.next(unsubMsg()); - } - catch (err) { - observer.error(err); - } - subscription.unsubscribe(); - }; - }); - }; - WebSocketSubject.prototype._connectSocket = function () { - var _this = this; - var _a = this._config, WebSocketCtor = _a.WebSocketCtor, protocol = _a.protocol, url = _a.url, binaryType = _a.binaryType; - var observer = this._output; - var socket = null; - try { - socket = protocol ? - new WebSocketCtor(url, protocol) : - new WebSocketCtor(url); - this._socket = socket; - if (binaryType) { - this._socket.binaryType = binaryType; - } - } - catch (e) { - observer.error(e); - return; - } - var subscription = new Subscription_1.Subscription(function () { - _this._socket = null; - if (socket && socket.readyState === 1) { - socket.close(); - } - }); - socket.onopen = function (e) { - var _socket = _this._socket; - if (!_socket) { - socket.close(); - _this._resetState(); - return; - } - var openObserver = _this._config.openObserver; - if (openObserver) { - openObserver.next(e); - } - var queue = _this.destination; - _this.destination = Subscriber_1.Subscriber.create(function (x) { - if (socket.readyState === 1) { - try { - var serializer = _this._config.serializer; - socket.send(serializer(x)); - } - catch (e) { - _this.destination.error(e); - } - } - }, function (e) { - var closingObserver = _this._config.closingObserver; - if (closingObserver) { - closingObserver.next(undefined); - } - if (e && e.code) { - socket.close(e.code, e.reason); - } - else { - observer.error(new TypeError(WEBSOCKETSUBJECT_INVALID_ERROR_OBJECT)); - } - _this._resetState(); - }, function () { - var closingObserver = _this._config.closingObserver; - if (closingObserver) { - closingObserver.next(undefined); - } - socket.close(); - _this._resetState(); - }); - if (queue && queue instanceof ReplaySubject_1.ReplaySubject) { - subscription.add(queue.subscribe(_this.destination)); - } - }; - socket.onerror = function (e) { - _this._resetState(); - observer.error(e); - }; - socket.onclose = function (e) { - _this._resetState(); - var closeObserver = _this._config.closeObserver; - if (closeObserver) { - closeObserver.next(e); - } - if (e.wasClean) { - observer.complete(); - } - else { - observer.error(e); - } - }; - socket.onmessage = function (e) { - try { - var deserializer = _this._config.deserializer; - observer.next(deserializer(e)); - } - catch (err) { - observer.error(err); - } - }; - }; - WebSocketSubject.prototype._subscribe = function (subscriber) { - var _this = this; - var source = this.source; - if (source) { - return source.subscribe(subscriber); - } - if (!this._socket) { - this._connectSocket(); - } - this._output.subscribe(subscriber); - subscriber.add(function () { - var _socket = _this._socket; - if (_this._output.observers.length === 0) { - if (_socket && _socket.readyState === 1) { - _socket.close(); - } - _this._resetState(); - } - }); - return subscriber; - }; - WebSocketSubject.prototype.unsubscribe = function () { - var _socket = this._socket; - if (_socket && _socket.readyState === 1) { - _socket.close(); - } - this._resetState(); - _super.prototype.unsubscribe.call(this); - }; - return WebSocketSubject; -}(Subject_1.AnonymousSubject)); -exports.WebSocketSubject = WebSocketSubject; -//# sourceMappingURL=WebSocketSubject.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/WebSocketSubject.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/WebSocketSubject.js.map deleted file mode 100644 index da0ce6a2..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/WebSocketSubject.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"WebSocketSubject.js","sources":["../../../src/internal/observable/dom/WebSocketSubject.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,yCAA0D;AAC1D,+CAA8C;AAC9C,+CAA8C;AAC9C,mDAAkD;AAElD,qDAAoD;AAsIpD,IAAM,wBAAwB,GAAgC;IAC5D,GAAG,EAAE,EAAE;IACP,YAAY,EAAE,UAAC,CAAe,IAAK,OAAA,IAAI,CAAC,KAAK,CAAC,CAAC,CAAC,IAAI,CAAC,EAAlB,CAAkB;IACrD,UAAU,EAAE,UAAC,KAAU,IAAK,OAAA,IAAI,CAAC,SAAS,CAAC,KAAK,CAAC,EAArB,CAAqB;CAClD,CAAC;AAEF,IAAM,qCAAqC,GACzC,mIAAmI,CAAC;AAItI;IAAyC,oCAAmB;IAS1D,0BAAY,iBAAqE,EAAE,WAAyB;QAA5G,YACE,iBAAO,SAwBR;QAvBC,IAAI,iBAAiB,YAAY,uBAAU,EAAE;YAC3C,KAAI,CAAC,WAAW,GAAG,WAAW,CAAC;YAC/B,KAAI,CAAC,MAAM,GAAG,iBAAkC,CAAC;SAClD;aAAM;YACL,IAAM,MAAM,GAAG,KAAI,CAAC,OAAO,gBAAQ,wBAAwB,CAAE,CAAC;YAC9D,KAAI,CAAC,OAAO,GAAG,IAAI,iBAAO,EAAK,CAAC;YAChC,IAAI,OAAO,iBAAiB,KAAK,QAAQ,EAAE;gBACzC,MAAM,CAAC,GAAG,GAAG,iBAAiB,CAAC;aAChC;iBAAM;gBACL,KAAK,IAAI,GAAG,IAAI,iBAAiB,EAAE;oBACjC,IAAI,iBAAiB,CAAC,cAAc,CAAC,GAAG,CAAC,EAAE;wBACzC,MAAM,CAAC,GAAG,CAAC,GAAG,iBAAiB,CAAC,GAAG,CAAC,CAAC;qBACtC;iBACF;aACF;YAED,IAAI,CAAC,MAAM,CAAC,aAAa,IAAI,SAAS,EAAE;gBACtC,MAAM,CAAC,aAAa,GAAG,SAAS,CAAC;aAClC;iBAAM,IAAI,CAAC,MAAM,CAAC,aAAa,EAAE;gBAChC,MAAM,IAAI,KAAK,CAAC,uCAAuC,CAAC,CAAC;aAC1D;YACD,KAAI,CAAC,WAAW,GAAG,IAAI,6BAAa,EAAE,CAAC;SACxC;;IACH,CAAC;IAED,+BAAI,GAAJ,UAAQ,QAAwB;QAC9B,IAAM,IAAI,GAAG,IAAI,gBAAgB,CAAI,IAAI,CAAC,OAAsC,EAAQ,IAAI,CAAC,WAAW,CAAC,CAAC;QAC1G,IAAI,CAAC,QAAQ,GAAG,QAAQ,CAAC;QACzB,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC;QACnB,OAAO,IAAI,CAAC;IACd,CAAC;IAEO,sCAAW,GAAnB;QACE,IAAI,CAAC,OAAO,GAAG,IAAI,CAAC;QACpB,IAAI,CAAC,IAAI,CAAC,MAAM,EAAE;YAChB,IAAI,CAAC,WAAW,GAAG,IAAI,6BAAa,EAAE,CAAC;SACxC;QACD,IAAI,CAAC,OAAO,GAAG,IAAI,iBAAO,EAAK,CAAC;IAClC,CAAC;IAoBD,oCAAS,GAAT,UAAU,MAAiB,EAAE,QAAmB,EAAE,aAAoC;QACpF,IAAM,IAAI,GAAG,IAAI,CAAC;QAClB,OAAO,IAAI,uBAAU,CAAC,UAAC,QAAuB;YAC5C,IAAI;gBACF,IAAI,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC,CAAC;aACrB;YAAC,OAAO,GAAG,EAAE;gBACZ,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;aACrB;YAED,IAAM,YAAY,GAAG,IAAI,CAAC,SAAS,CAAC,UAAA,CAAC;gBACnC,IAAI;oBACF,IAAI,aAAa,CAAC,CAAC,CAAC,EAAE;wBACpB,QAAQ,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;qBAClB;iBACF;gBAAC,OAAO,GAAG,EAAE;oBACZ,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;iBACrB;YACH,CAAC,EACC,UAAA,GAAG,IAAI,OAAA,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,EAAnB,CAAmB,EAC1B,cAAM,OAAA,QAAQ,CAAC,QAAQ,EAAE,EAAnB,CAAmB,CAAC,CAAC;YAE7B,OAAO;gBACL,IAAI;oBACF,IAAI,CAAC,IAAI,CAAC,QAAQ,EAAE,CAAC,CAAC;iBACvB;gBAAC,OAAO,GAAG,EAAE;oBACZ,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;iBACrB;gBACD,YAAY,CAAC,WAAW,EAAE,CAAC;YAC7B,CAAC,CAAC;QACJ,CAAC,CAAC,CAAC;IACL,CAAC;IAEO,yCAAc,GAAtB;QAAA,iBAuGC;QAtGO,IAAA,iBAA2D,EAAzD,gCAAa,EAAE,sBAAQ,EAAE,YAAG,EAAE,0BAAU,CAAkB;QAClE,IAAM,QAAQ,GAAG,IAAI,CAAC,OAAO,CAAC;QAE9B,IAAI,MAAM,GAAc,IAAI,CAAC;QAC7B,IAAI;YACF,MAAM,GAAG,QAAQ,CAAC,CAAC;gBACjB,IAAI,aAAa,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,CAAC;gBAClC,IAAI,aAAa,CAAC,GAAG,CAAC,CAAC;YACzB,IAAI,CAAC,OAAO,GAAG,MAAM,CAAC;YACtB,IAAI,UAAU,EAAE;gBACd,IAAI,CAAC,OAAO,CAAC,UAAU,GAAG,UAAU,CAAC;aACtC;SACF;QAAC,OAAO,CAAC,EAAE;YACV,QAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;YAClB,OAAO;SACR;QAED,IAAM,YAAY,GAAG,IAAI,2BAAY,CAAC;YACpC,KAAI,CAAC,OAAO,GAAG,IAAI,CAAC;YACpB,IAAI,MAAM,IAAI,MAAM,CAAC,UAAU,KAAK,CAAC,EAAE;gBACrC,MAAM,CAAC,KAAK,EAAE,CAAC;aAChB;QACH,CAAC,CAAC,CAAC;QAEH,MAAM,CAAC,MAAM,GAAG,UAAC,CAAQ;YACf,IAAA,uBAAO,CAAU;YACzB,IAAI,CAAC,OAAO,EAAE;gBACZ,MAAM,CAAC,KAAK,EAAE,CAAC;gBACf,KAAI,CAAC,WAAW,EAAE,CAAC;gBACnB,OAAO;aACR;YACO,IAAA,yCAAY,CAAkB;YACtC,IAAI,YAAY,EAAE;gBAChB,YAAY,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;aACtB;YAED,IAAM,KAAK,GAAG,KAAI,CAAC,WAAW,CAAC;YAE/B,KAAI,CAAC,WAAW,GAAG,uBAAU,CAAC,MAAM,CAClC,UAAC,CAAC;gBACA,IAAI,MAAM,CAAC,UAAU,KAAK,CAAC,EAAE;oBAC3B,IAAI;wBACM,IAAA,qCAAU,CAAkB;wBACpC,MAAM,CAAC,IAAI,CAAC,UAAU,CAAC,CAAC,CAAC,CAAC,CAAC;qBAC1B;oBAAC,OAAO,CAAC,EAAE;wBACZ,KAAI,CAAC,WAAW,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;qBAC3B;iBACF;YACH,CAAC,EACD,UAAC,CAAC;gBACQ,IAAA,+CAAe,CAAkB;gBACzC,IAAI,eAAe,EAAE;oBACnB,eAAe,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;iBACjC;gBACD,IAAI,CAAC,IAAI,CAAC,CAAC,IAAI,EAAE;oBACf,MAAM,CAAC,KAAK,CAAC,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC,MAAM,CAAC,CAAC;iBAChC;qBAAM;oBACL,QAAQ,CAAC,KAAK,CAAC,IAAI,SAAS,CAAC,qCAAqC,CAAC,CAAC,CAAC;iBACtE;gBACD,KAAI,CAAC,WAAW,EAAE,CAAC;YACrB,CAAC,EACD;gBACU,IAAA,+CAAe,CAAkB;gBACzC,IAAI,eAAe,EAAE;oBACnB,eAAe,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;iBACjC;gBACD,MAAM,CAAC,KAAK,EAAE,CAAC;gBACf,KAAI,CAAC,WAAW,EAAE,CAAC;YACrB,CAAC,CACiB,CAAC;YAErB,IAAI,KAAK,IAAI,KAAK,YAAY,6BAAa,EAAE;gBAC3C,YAAY,CAAC,GAAG,CAAoB,KAAM,CAAC,SAAS,CAAC,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC;aACzE;QACH,CAAC,CAAC;QAEF,MAAM,CAAC,OAAO,GAAG,UAAC,CAAQ;YACxB,KAAI,CAAC,WAAW,EAAE,CAAC;YACnB,QAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;QACpB,CAAC,CAAC;QAEF,MAAM,CAAC,OAAO,GAAG,UAAC,CAAa;YAC7B,KAAI,CAAC,WAAW,EAAE,CAAC;YACX,IAAA,2CAAa,CAAkB;YACvC,IAAI,aAAa,EAAE;gBACjB,aAAa,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;aACvB;YACD,IAAI,CAAC,CAAC,QAAQ,EAAE;gBACd,QAAQ,CAAC,QAAQ,EAAE,CAAC;aACrB;iBAAM;gBACL,QAAQ,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;aACnB;QACH,CAAC,CAAC;QAEF,MAAM,CAAC,SAAS,GAAG,UAAC,CAAe;YACjC,IAAI;gBACM,IAAA,yCAAY,CAAkB;gBACtC,QAAQ,CAAC,IAAI,CAAC,YAAY,CAAC,CAAC,CAAC,CAAC,CAAC;aAChC;YAAC,OAAO,GAAG,EAAE;gBACZ,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;aACrB;QACH,CAAC,CAAC;IACJ,CAAC;IAGD,qCAAU,GAAV,UAAW,UAAyB;QAApC,iBAmBC;QAlBS,IAAA,oBAAM,CAAU;QACxB,IAAI,MAAM,EAAE;YACV,OAAO,MAAM,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;SACrC;QACD,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE;YACjB,IAAI,CAAC,cAAc,EAAE,CAAC;SACvB;QACD,IAAI,CAAC,OAAO,CAAC,SAAS,CAAC,UAAU,CAAC,CAAC;QACnC,UAAU,CAAC,GAAG,CAAC;YACL,IAAA,uBAAO,CAAU;YACzB,IAAI,KAAI,CAAC,OAAO,CAAC,SAAS,CAAC,MAAM,KAAK,CAAC,EAAE;gBACvC,IAAI,OAAO,IAAI,OAAO,CAAC,UAAU,KAAK,CAAC,EAAE;oBACvC,OAAO,CAAC,KAAK,EAAE,CAAC;iBACjB;gBACD,KAAI,CAAC,WAAW,EAAE,CAAC;aACpB;QACH,CAAC,CAAC,CAAC;QACH,OAAO,UAAU,CAAC;IACpB,CAAC;IAED,sCAAW,GAAX;QACU,IAAA,sBAAO,CAAU;QACzB,IAAI,OAAO,IAAI,OAAO,CAAC,UAAU,KAAK,CAAC,EAAE;YACvC,OAAO,CAAC,KAAK,EAAE,CAAC;SACjB;QACD,IAAI,CAAC,WAAW,EAAE,CAAC;QACnB,iBAAM,WAAW,WAAE,CAAC;IACtB,CAAC;IACH,uBAAC;AAAD,CAAC,AA5OD,CAAyC,0BAAgB,GA4OxD;AA5OY,4CAAgB"} diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/ajax.d.ts b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/ajax.d.ts deleted file mode 100644 index 72e29f45..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/ajax.d.ts +++ /dev/null @@ -1,82 +0,0 @@ -import { AjaxCreationMethod } from './AjaxObservable'; -/** - * There is an ajax operator on the Rx object. - * - * It creates an observable for an Ajax request with either a request object with - * url, headers, etc or a string for a URL. - * - * - * ## Using ajax() to fetch the response object that is being returned from API. - * ```ts - * import { ajax } from 'rxjs/ajax'; - * import { map, catchError } from 'rxjs/operators'; - * import { of } from 'rxjs'; - * - * const obs$ = ajax(`https://api.github.com/users?per_page=5`).pipe( - * map(userResponse => console.log('users: ', userResponse)), - * catchError(error => { - * console.log('error: ', error); - * return of(error); - * }) - * ); - * - * ``` - * - * ## Using ajax.getJSON() to fetch data from API. - * ```ts - * import { ajax } from 'rxjs/ajax'; - * import { map, catchError } from 'rxjs/operators'; - * import { of } from 'rxjs'; - * - * const obs$ = ajax.getJSON(`https://api.github.com/users?per_page=5`).pipe( - * map(userResponse => console.log('users: ', userResponse)), - * catchError(error => { - * console.log('error: ', error); - * return of(error); - * }) - * ); - * - * ``` - * - * ## Using ajax() with object as argument and method POST with a two seconds delay. - * ```ts - * import { ajax } from 'rxjs/ajax'; - * import { of } from 'rxjs'; - * - * const users = ajax({ - * url: 'https://httpbin.org/delay/2', - * method: 'POST', - * headers: { - * 'Content-Type': 'application/json', - * 'rxjs-custom-header': 'Rxjs' - * }, - * body: { - * rxjs: 'Hello World!' - * } - * }).pipe( - * map(response => console.log('response: ', response)), - * catchError(error => { - * console.log('error: ', error); - * return of(error); - * }) - * ); - * - * ``` - * - * ## Using ajax() to fetch. An error object that is being returned from the request. - * ```ts - * import { ajax } from 'rxjs/ajax'; - * import { map, catchError } from 'rxjs/operators'; - * import { of } from 'rxjs'; - * - * const obs$ = ajax(`https://api.github.com/404`).pipe( - * map(userResponse => console.log('users: ', userResponse)), - * catchError(error => { - * console.log('error: ', error); - * return of(error); - * }) - * ); - * - * ``` - */ -export declare const ajax: AjaxCreationMethod; diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/ajax.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/ajax.js deleted file mode 100644 index b7399e13..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/ajax.js +++ /dev/null @@ -1,5 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -var AjaxObservable_1 = require("./AjaxObservable"); -exports.ajax = (function () { return AjaxObservable_1.AjaxObservable.create; })(); -//# sourceMappingURL=ajax.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/ajax.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/ajax.js.map deleted file mode 100644 index 8f4e299e..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/ajax.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"ajax.js","sources":["../../../src/internal/observable/dom/ajax.ts"],"names":[],"mappings":";;AAAA,mDAAwE;AAiF3D,QAAA,IAAI,GAAuB,CAAC,cAAM,OAAA,+BAAc,CAAC,MAAM,EAArB,CAAqB,CAAC,EAAE,CAAC"} diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/fetch.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/fetch.js deleted file mode 100644 index ac7694bd..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/fetch.js +++ /dev/null @@ -1,90 +0,0 @@ -"use strict"; -var __assign = (this && this.__assign) || function () { - __assign = Object.assign || function(t) { - for (var s, i = 1, n = arguments.length; i < n; i++) { - s = arguments[i]; - for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p)) - t[p] = s[p]; - } - return t; - }; - return __assign.apply(this, arguments); -}; -var __rest = (this && this.__rest) || function (s, e) { - var t = {}; - for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p) && e.indexOf(p) < 0) - t[p] = s[p]; - if (s != null && typeof Object.getOwnPropertySymbols === "function") - for (var i = 0, p = Object.getOwnPropertySymbols(s); i < p.length; i++) if (e.indexOf(p[i]) < 0) - t[p[i]] = s[p[i]]; - return t; -}; -Object.defineProperty(exports, "__esModule", { value: true }); -var Observable_1 = require("../../Observable"); -var Subscription_1 = require("../../Subscription"); -var from_1 = require("../../observable/from"); -function fromFetch(input, initWithSelector) { - if (initWithSelector === void 0) { initWithSelector = {}; } - var selector = initWithSelector.selector, init = __rest(initWithSelector, ["selector"]); - return new Observable_1.Observable(function (subscriber) { - var controller = new AbortController(); - var signal = controller.signal; - var abortable = true; - var unsubscribed = false; - var subscription = new Subscription_1.Subscription(); - subscription.add(function () { - unsubscribed = true; - if (abortable) { - controller.abort(); - } - }); - var perSubscriberInit; - if (init) { - if (init.signal) { - if (init.signal.aborted) { - controller.abort(); - } - else { - var outerSignal_1 = init.signal; - var outerSignalHandler_1 = function () { - if (!signal.aborted) { - controller.abort(); - } - }; - outerSignal_1.addEventListener('abort', outerSignalHandler_1); - subscription.add(function () { return outerSignal_1.removeEventListener('abort', outerSignalHandler_1); }); - } - } - perSubscriberInit = __assign({}, init, { signal: signal }); - } - else { - perSubscriberInit = { signal: signal }; - } - fetch(input, perSubscriberInit).then(function (response) { - if (selector) { - subscription.add(from_1.from(selector(response)).subscribe(function (value) { return subscriber.next(value); }, function (err) { - abortable = false; - if (!unsubscribed) { - subscriber.error(err); - } - }, function () { - abortable = false; - subscriber.complete(); - })); - } - else { - abortable = false; - subscriber.next(response); - subscriber.complete(); - } - }).catch(function (err) { - abortable = false; - if (!unsubscribed) { - subscriber.error(err); - } - }); - return subscription; - }); -} -exports.fromFetch = fromFetch; -//# sourceMappingURL=fetch.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/fetch.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/fetch.js.map deleted file mode 100644 index 0a4b31be..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/fetch.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"fetch.js","sources":["../../../src/internal/observable/dom/fetch.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;AAAA,+CAA8C;AAC9C,mDAAkD;AAClD,8CAA6C;AA8F7C,SAAgB,SAAS,CACvB,KAAuB,EACvB,gBAEM;IAFN,iCAAA,EAAA,qBAEM;IAEE,IAAA,oCAAQ,EAAE,6CAAO,CAAsB;IAC/C,OAAO,IAAI,uBAAU,CAAe,UAAA,UAAU;QAC5C,IAAM,UAAU,GAAG,IAAI,eAAe,EAAE,CAAC;QACzC,IAAM,MAAM,GAAG,UAAU,CAAC,MAAM,CAAC;QACjC,IAAI,SAAS,GAAG,IAAI,CAAC;QACrB,IAAI,YAAY,GAAG,KAAK,CAAC;QAEzB,IAAM,YAAY,GAAG,IAAI,2BAAY,EAAE,CAAC;QACxC,YAAY,CAAC,GAAG,CAAC;YACf,YAAY,GAAG,IAAI,CAAC;YACpB,IAAI,SAAS,EAAE;gBACb,UAAU,CAAC,KAAK,EAAE,CAAC;aACpB;QACH,CAAC,CAAC,CAAC;QAEH,IAAI,iBAA8B,CAAC;QACnC,IAAI,IAAI,EAAE;YAER,IAAI,IAAI,CAAC,MAAM,EAAE;gBACf,IAAI,IAAI,CAAC,MAAM,CAAC,OAAO,EAAE;oBACvB,UAAU,CAAC,KAAK,EAAE,CAAC;iBACpB;qBAAM;oBACL,IAAM,aAAW,GAAG,IAAI,CAAC,MAAM,CAAC;oBAChC,IAAM,oBAAkB,GAAG;wBACzB,IAAI,CAAC,MAAM,CAAC,OAAO,EAAE;4BACnB,UAAU,CAAC,KAAK,EAAE,CAAC;yBACpB;oBACH,CAAC,CAAC;oBACF,aAAW,CAAC,gBAAgB,CAAC,OAAO,EAAE,oBAAkB,CAAC,CAAC;oBAC1D,YAAY,CAAC,GAAG,CAAC,cAAM,OAAA,aAAW,CAAC,mBAAmB,CAAC,OAAO,EAAE,oBAAkB,CAAC,EAA5D,CAA4D,CAAC,CAAC;iBACtF;aACF;YAGD,iBAAiB,gBAAQ,IAAI,IAAE,MAAM,QAAA,GAAE,CAAC;SACzC;aAAM;YACL,iBAAiB,GAAG,EAAE,MAAM,QAAA,EAAE,CAAC;SAChC;QAED,KAAK,CAAC,KAAK,EAAE,iBAAiB,CAAC,CAAC,IAAI,CAAC,UAAA,QAAQ;YAC3C,IAAI,QAAQ,EAAE;gBACZ,YAAY,CAAC,GAAG,CAAC,WAAI,CAAC,QAAQ,CAAC,QAAQ,CAAC,CAAC,CAAC,SAAS,CACjD,UAAA,KAAK,IAAI,OAAA,UAAU,CAAC,IAAI,CAAC,KAAK,CAAC,EAAtB,CAAsB,EAC/B,UAAA,GAAG;oBACD,SAAS,GAAG,KAAK,CAAC;oBAClB,IAAI,CAAC,YAAY,EAAE;wBAEjB,UAAU,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;qBACvB;gBACH,CAAC,EACD;oBACE,SAAS,GAAG,KAAK,CAAC;oBAClB,UAAU,CAAC,QAAQ,EAAE,CAAC;gBACxB,CAAC,CACF,CAAC,CAAC;aACJ;iBAAM;gBACL,SAAS,GAAG,KAAK,CAAC;gBAClB,UAAU,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;gBAC1B,UAAU,CAAC,QAAQ,EAAE,CAAC;aACvB;QACH,CAAC,CAAC,CAAC,KAAK,CAAC,UAAA,GAAG;YACV,SAAS,GAAG,KAAK,CAAC;YAClB,IAAI,CAAC,YAAY,EAAE;gBAEjB,UAAU,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;aACvB;QACH,CAAC,CAAC,CAAC;QAEH,OAAO,YAAY,CAAC;IACtB,CAAC,CAAC,CAAC;AACL,CAAC;AA5ED,8BA4EC"} diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/webSocket.js b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/webSocket.js deleted file mode 100644 index 714cf95c..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/webSocket.js +++ /dev/null @@ -1,8 +0,0 @@ -"use strict"; -Object.defineProperty(exports, "__esModule", { value: true }); -var WebSocketSubject_1 = require("./WebSocketSubject"); -function webSocket(urlConfigOrSource) { - return new WebSocketSubject_1.WebSocketSubject(urlConfigOrSource); -} -exports.webSocket = webSocket; -//# sourceMappingURL=webSocket.js.map
\ No newline at end of file diff --git a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/webSocket.js.map b/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/webSocket.js.map deleted file mode 100644 index 1d0f249f..00000000 --- a/sandbox/testAppNevena/Front/node_modules/rxjs/internal/observable/dom/webSocket.js.map +++ /dev/null @@ -1 +0,0 @@ -{"version":3,"file":"webSocket.js","sources":["../../../src/internal/observable/dom/webSocket.ts"],"names":[],"mappings":";;AAAA,uDAA8E;AAyJ9E,SAAgB,SAAS,CAAI,iBAAqD;IAChF,OAAO,IAAI,mCAAgB,CAAI,iBAAiB,CAAC,CAAC;AACpD,CAAC;AAFD,8BAEC"} |