remove dev node_modules (oops)

8 files changed, 0 insertions, 379 deletions

diff --git a/node_modules/rxjs/dist/cjs/internal/observable/dom/WebSocketSubject.js b/node_modules/rxjs/dist/cjs/internal/observable/dom/WebSocketSubject.js
deleted file mode 100644
index cead103..0000000
--- a/node_modules/rxjs/dist/cjs/internal/observable/dom/WebSocketSubject.js
+++ /dev/null
@@ -1,249 +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 (Object.prototype.hasOwnProperty.call(b, p)) d[p] = b[p]; };
-        return extendStatics(d, b);
-    };
-    return function (d, b) {
-        if (typeof b !== "function" && b !== null)
-            throw new TypeError("Class extends value " + String(b) + " is not a constructor or null");
-        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 });
-exports.WebSocketSubject = void 0;
-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;
-        _this._socket = null;
-        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({
-                next: function (x) {
-                    try {
-                        if (messageFilter(x)) {
-                            observer.next(x);
-                        }
-                    }
-                    catch (err) {
-                        observer.error(err);
-                    }
-                },
-                error: function (err) { return observer.error(err); },
-                complete: 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 (evt) {
-            var _socket = _this._socket;
-            if (!_socket) {
-                socket.close();
-                _this._resetState();
-                return;
-            }
-            var openObserver = _this._config.openObserver;
-            if (openObserver) {
-                openObserver.next(evt);
-            }
-            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 (err) {
-                var closingObserver = _this._config.closingObserver;
-                if (closingObserver) {
-                    closingObserver.next(undefined);
-                }
-                if (err && err.code) {
-                    socket.close(err.code, err.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) {
-            if (socket === _this._socket) {
-                _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.readyState === 0)) {
-                    _socket.close();
-                }
-                _this._resetState();
-            }
-        });
-        return subscriber;
-    };
-    WebSocketSubject.prototype.unsubscribe = function () {
-        var _socket = this._socket;
-        if (_socket && (_socket.readyState === 1 || _socket.readyState === 0)) {
-            _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/node_modules/rxjs/dist/cjs/internal/observable/dom/WebSocketSubject.js.map b/node_modules/rxjs/dist/cjs/internal/observable/dom/WebSocketSubject.js.map
deleted file mode 100644
index ec11b0b..0000000
--- a/node_modules/rxjs/dist/cjs/internal/observable/dom/WebSocketSubject.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"WebSocketSubject.js","sourceRoot":"","sources":["../../../../../src/internal/observable/dom/WebSocketSubject.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,yCAA0D;AAC1D,+CAA8C;AAC9C,+CAA8C;AAC9C,mDAAkD;AAElD,qDAAoD;AA4IpD,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;IAU1D,0BAAY,iBAAqE,EAAE,WAAyB;QAA5G,YACE,iBAAO,SAwBR;QA3BO,aAAO,GAAqB,IAAI,CAAC;QAIvC,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,CAAC,KAAI,CAAC,OAAO,gBAAQ,wBAAwB,CAAE,CAAC,CAAC;YAChE,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,IAAM,GAAG,IAAI,iBAAiB,EAAE;oBACnC,IAAI,iBAAiB,CAAC,cAAc,CAAC,GAAG,CAAC,EAAE;wBACxC,MAAc,CAAC,GAAG,CAAC,GAAI,iBAAyB,CAAC,GAAG,CAAC,CAAC;qBACxD;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;IAGD,+BAAI,GAAJ,UAAQ,QAAwB;QAC9B,IAAM,IAAI,GAAG,IAAI,gBAAgB,CAAI,IAAI,CAAC,OAAsC,EAAE,IAAI,CAAC,WAAkB,CAAC,CAAC;QAC3G,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,QAAqB;YAC1C,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;gBAClC,IAAI,EAAE,UAAC,CAAC;oBACN,IAAI;wBACF,IAAI,aAAa,CAAC,CAAC,CAAC,EAAE;4BACpB,QAAQ,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;yBAClB;qBACF;oBAAC,OAAO,GAAG,EAAE;wBACZ,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;qBACrB;gBACH,CAAC;gBACD,KAAK,EAAE,UAAC,GAAG,IAAK,OAAA,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,EAAnB,CAAmB;gBACnC,QAAQ,EAAE,cAAM,OAAA,QAAQ,CAAC,QAAQ,EAAE,EAAnB,CAAmB;aACpC,CAAC,CAAC;YAEH,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,KAA+C,IAAI,CAAC,OAAO,EAAzD,aAAa,mBAAA,EAAE,QAAQ,cAAA,EAAE,GAAG,SAAA,EAAE,UAAU,gBAAiB,CAAC;QAClE,IAAM,QAAQ,GAAG,IAAI,CAAC,OAAO,CAAC;QAE9B,IAAI,MAAM,GAAqB,IAAI,CAAC;QACpC,IAAI;YACF,MAAM,GAAG,QAAQ,CAAC,CAAC,CAAC,IAAI,aAAc,CAAC,GAAG,EAAE,QAAQ,CAAC,CAAC,CAAC,CAAC,IAAI,aAAc,CAAC,GAAG,CAAC,CAAC;YAChF,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,GAAU;YACjB,IAAA,OAAO,GAAK,KAAI,QAAT,CAAU;YACzB,IAAI,CAAC,OAAO,EAAE;gBACZ,MAAO,CAAC,KAAK,EAAE,CAAC;gBAChB,KAAI,CAAC,WAAW,EAAE,CAAC;gBACnB,OAAO;aACR;YACO,IAAA,YAAY,GAAK,KAAI,CAAC,OAAO,aAAjB,CAAkB;YACtC,IAAI,YAAY,EAAE;gBAChB,YAAY,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;aACxB;YAED,IAAM,KAAK,GAAG,KAAI,CAAC,WAAW,CAAC;YAE/B,KAAI,CAAC,WAAW,GAAG,uBAAU,CAAC,MAAM,CAClC,UAAC,CAAC;gBACA,IAAI,MAAO,CAAC,UAAU,KAAK,CAAC,EAAE;oBAC5B,IAAI;wBACM,IAAA,UAAU,GAAK,KAAI,CAAC,OAAO,WAAjB,CAAkB;wBACpC,MAAO,CAAC,IAAI,CAAC,UAAW,CAAC,CAAE,CAAC,CAAC,CAAC;qBAC/B;oBAAC,OAAO,CAAC,EAAE;wBACV,KAAI,CAAC,WAAY,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;qBAC5B;iBACF;YACH,CAAC,EACD,UAAC,GAAG;gBACM,IAAA,eAAe,GAAK,KAAI,CAAC,OAAO,gBAAjB,CAAkB;gBACzC,IAAI,eAAe,EAAE;oBACnB,eAAe,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;iBACjC;gBACD,IAAI,GAAG,IAAI,GAAG,CAAC,IAAI,EAAE;oBACnB,MAAO,CAAC,KAAK,CAAC,GAAG,CAAC,IAAI,EAAE,GAAG,CAAC,MAAM,CAAC,CAAC;iBACrC;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,eAAe,GAAK,KAAI,CAAC,OAAO,gBAAjB,CAAkB;gBACzC,IAAI,eAAe,EAAE;oBACnB,eAAe,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;iBACjC;gBACD,MAAO,CAAC,KAAK,EAAE,CAAC;gBAChB,KAAI,CAAC,WAAW,EAAE,CAAC;YACrB,CAAC,CACiB,CAAC;YAErB,IAAI,KAAK,IAAI,KAAK,YAAY,6BAAa,EAAE;gBAC3C,YAAY,CAAC,GAAG,CAAE,KAA0B,CAAC,SAAS,CAAC,KAAI,CAAC,WAAW,CAAC,CAAC,CAAC;aAC3E;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,IAAI,MAAM,KAAK,KAAI,CAAC,OAAO,EAAE;gBAC3B,KAAI,CAAC,WAAW,EAAE,CAAC;aACpB;YACO,IAAA,aAAa,GAAK,KAAI,CAAC,OAAO,cAAjB,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,YAAY,GAAK,KAAI,CAAC,OAAO,aAAjB,CAAkB;gBACtC,QAAQ,CAAC,IAAI,CAAC,YAAa,CAAC,CAAC,CAAC,CAAC,CAAC;aACjC;YAAC,OAAO,GAAG,EAAE;gBACZ,QAAQ,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;aACrB;QACH,CAAC,CAAC;IACJ,CAAC;IAGS,qCAAU,GAApB,UAAqB,UAAyB;QAA9C,iBAmBC;QAlBS,IAAA,MAAM,GAAK,IAAI,OAAT,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,OAAO,GAAK,KAAI,QAAT,CAAU;YACzB,IAAI,KAAI,CAAC,OAAO,CAAC,SAAS,CAAC,MAAM,KAAK,CAAC,EAAE;gBACvC,IAAI,OAAO,IAAI,CAAC,OAAO,CAAC,UAAU,KAAK,CAAC,IAAI,OAAO,CAAC,UAAU,KAAK,CAAC,CAAC,EAAE;oBACrE,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,OAAO,GAAK,IAAI,QAAT,CAAU;QACzB,IAAI,OAAO,IAAI,CAAC,OAAO,CAAC,UAAU,KAAK,CAAC,IAAI,OAAO,CAAC,UAAU,KAAK,CAAC,CAAC,EAAE;YACrE,OAAO,CAAC,KAAK,EAAE,CAAC;SACjB;QACD,IAAI,CAAC,WAAW,EAAE,CAAC;QACnB,iBAAM,WAAW,WAAE,CAAC;IACtB,CAAC;IACH,uBAAC;AAAD,CAAC,AAhPD,CAAyC,0BAAgB,GAgPxD;AAhPY,4CAAgB"}
\ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/observable/dom/animationFrames.js b/node_modules/rxjs/dist/cjs/internal/observable/dom/animationFrames.js
deleted file mode 100644
index aeb24d1..0000000
--- a/node_modules/rxjs/dist/cjs/internal/observable/dom/animationFrames.js
+++ /dev/null
@@ -1,38 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.animationFrames = void 0;
-var Observable_1 = require("../../Observable");
-var performanceTimestampProvider_1 = require("../../scheduler/performanceTimestampProvider");
-var animationFrameProvider_1 = require("../../scheduler/animationFrameProvider");
-function animationFrames(timestampProvider) {
-    return timestampProvider ? animationFramesFactory(timestampProvider) : DEFAULT_ANIMATION_FRAMES;
-}
-exports.animationFrames = animationFrames;
-function animationFramesFactory(timestampProvider) {
-    return new Observable_1.Observable(function (subscriber) {
-        var provider = timestampProvider || performanceTimestampProvider_1.performanceTimestampProvider;
-        var start = provider.now();
-        var id = 0;
-        var run = function () {
-            if (!subscriber.closed) {
-                id = animationFrameProvider_1.animationFrameProvider.requestAnimationFrame(function (timestamp) {
-                    id = 0;
-                    var now = provider.now();
-                    subscriber.next({
-                        timestamp: timestampProvider ? now : timestamp,
-                        elapsed: now - start,
-                    });
-                    run();
-                });
-            }
-        };
-        run();
-        return function () {
-            if (id) {
-                animationFrameProvider_1.animationFrameProvider.cancelAnimationFrame(id);
-            }
-        };
-    });
-}
-var DEFAULT_ANIMATION_FRAMES = animationFramesFactory();
-//# sourceMappingURL=animationFrames.js.map
\ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/observable/dom/animationFrames.js.map b/node_modules/rxjs/dist/cjs/internal/observable/dom/animationFrames.js.map
deleted file mode 100644
index 3291a02..0000000
--- a/node_modules/rxjs/dist/cjs/internal/observable/dom/animationFrames.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"animationFrames.js","sourceRoot":"","sources":["../../../../../src/internal/observable/dom/animationFrames.ts"],"names":[],"mappings":";;;AAAA,+CAA8C;AAE9C,6FAA4F;AAC5F,iFAAgF;AAuEhF,SAAgB,eAAe,CAAC,iBAAqC;IACnE,OAAO,iBAAiB,CAAC,CAAC,CAAC,sBAAsB,CAAC,iBAAiB,CAAC,CAAC,CAAC,CAAC,wBAAwB,CAAC;AAClG,CAAC;AAFD,0CAEC;AAMD,SAAS,sBAAsB,CAAC,iBAAqC;IACnE,OAAO,IAAI,uBAAU,CAAyC,UAAC,UAAU;QAIvE,IAAM,QAAQ,GAAG,iBAAiB,IAAI,2DAA4B,CAAC;QAMnE,IAAM,KAAK,GAAG,QAAQ,CAAC,GAAG,EAAE,CAAC;QAE7B,IAAI,EAAE,GAAG,CAAC,CAAC;QACX,IAAM,GAAG,GAAG;YACV,IAAI,CAAC,UAAU,CAAC,MAAM,EAAE;gBACtB,EAAE,GAAG,+CAAsB,CAAC,qBAAqB,CAAC,UAAC,SAAuC;oBACxF,EAAE,GAAG,CAAC,CAAC;oBAQP,IAAM,GAAG,GAAG,QAAQ,CAAC,GAAG,EAAE,CAAC;oBAC3B,UAAU,CAAC,IAAI,CAAC;wBACd,SAAS,EAAE,iBAAiB,CAAC,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,SAAS;wBAC9C,OAAO,EAAE,GAAG,GAAG,KAAK;qBACrB,CAAC,CAAC;oBACH,GAAG,EAAE,CAAC;gBACR,CAAC,CAAC,CAAC;aACJ;QACH,CAAC,CAAC;QAEF,GAAG,EAAE,CAAC;QAEN,OAAO;YACL,IAAI,EAAE,EAAE;gBACN,+CAAsB,CAAC,oBAAoB,CAAC,EAAE,CAAC,CAAC;aACjD;QACH,CAAC,CAAC;IACJ,CAAC,CAAC,CAAC;AACL,CAAC;AAMD,IAAM,wBAAwB,GAAG,sBAAsB,EAAE,CAAC"}
\ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/observable/dom/fetch.js b/node_modules/rxjs/dist/cjs/internal/observable/dom/fetch.js
deleted file mode 100644
index 0bb09ef..0000000
--- a/node_modules/rxjs/dist/cjs/internal/observable/dom/fetch.js
+++ /dev/null
@@ -1,79 +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 && Object.prototype.propertyIsEnumerable.call(s, p[i]))
-                t[p[i]] = s[p[i]];
-        }
-    return t;
-};
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.fromFetch = void 0;
-var OperatorSubscriber_1 = require("../../operators/OperatorSubscriber");
-var Observable_1 = require("../../Observable");
-var innerFrom_1 = require("../../observable/innerFrom");
-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 outerSignal = init.signal;
-        if (outerSignal) {
-            if (outerSignal.aborted) {
-                controller.abort();
-            }
-            else {
-                var outerSignalHandler_1 = function () {
-                    if (!signal.aborted) {
-                        controller.abort();
-                    }
-                };
-                outerSignal.addEventListener('abort', outerSignalHandler_1);
-                subscriber.add(function () { return outerSignal.removeEventListener('abort', outerSignalHandler_1); });
-            }
-        }
-        var perSubscriberInit = __assign(__assign({}, init), { signal: signal });
-        var handleError = function (err) {
-            abortable = false;
-            subscriber.error(err);
-        };
-        fetch(input, perSubscriberInit)
-            .then(function (response) {
-            if (selector) {
-                innerFrom_1.innerFrom(selector(response)).subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, undefined, function () {
-                    abortable = false;
-                    subscriber.complete();
-                }, handleError));
-            }
-            else {
-                abortable = false;
-                subscriber.next(response);
-                subscriber.complete();
-            }
-        })
-            .catch(handleError);
-        return function () {
-            if (abortable) {
-                controller.abort();
-            }
-        };
-    });
-}
-exports.fromFetch = fromFetch;
-//# sourceMappingURL=fetch.js.map
\ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/observable/dom/fetch.js.map b/node_modules/rxjs/dist/cjs/internal/observable/dom/fetch.js.map
deleted file mode 100644
index a770094..0000000
--- a/node_modules/rxjs/dist/cjs/internal/observable/dom/fetch.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"fetch.js","sourceRoot":"","sources":["../../../../../src/internal/observable/dom/fetch.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;AAAA,yEAA8E;AAC9E,+CAA8C;AAC9C,wDAAuD;AA4FvD,SAAgB,SAAS,CACvB,KAAuB,EACvB,gBAEM;IAFN,iCAAA,EAAA,qBAEM;IAEE,IAAA,QAAQ,GAAc,gBAAgB,SAA9B,EAAK,IAAI,UAAK,gBAAgB,EAAxC,YAAqB,CAAF,CAAsB;IAC/C,OAAO,IAAI,uBAAU,CAAe,UAAC,UAAU;QAK7C,IAAM,UAAU,GAAG,IAAI,eAAe,EAAE,CAAC;QACjC,IAAA,MAAM,GAAK,UAAU,OAAf,CAAgB;QAK9B,IAAI,SAAS,GAAG,IAAI,CAAC;QAKb,IAAQ,WAAW,GAAK,IAAI,OAAT,CAAU;QACrC,IAAI,WAAW,EAAE;YACf,IAAI,WAAW,CAAC,OAAO,EAAE;gBACvB,UAAU,CAAC,KAAK,EAAE,CAAC;aACpB;iBAAM;gBAGL,IAAM,oBAAkB,GAAG;oBACzB,IAAI,CAAC,MAAM,CAAC,OAAO,EAAE;wBACnB,UAAU,CAAC,KAAK,EAAE,CAAC;qBACpB;gBACH,CAAC,CAAC;gBACF,WAAW,CAAC,gBAAgB,CAAC,OAAO,EAAE,oBAAkB,CAAC,CAAC;gBAC1D,UAAU,CAAC,GAAG,CAAC,cAAM,OAAA,WAAW,CAAC,mBAAmB,CAAC,OAAO,EAAE,oBAAkB,CAAC,EAA5D,CAA4D,CAAC,CAAC;aACpF;SACF;QAOD,IAAM,iBAAiB,yBAAqB,IAAI,KAAE,MAAM,QAAA,GAAE,CAAC;QAE3D,IAAM,WAAW,GAAG,UAAC,GAAQ;YAC3B,SAAS,GAAG,KAAK,CAAC;YAClB,UAAU,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;QACxB,CAAC,CAAC;QAEF,KAAK,CAAC,KAAK,EAAE,iBAAiB,CAAC;aAC5B,IAAI,CAAC,UAAC,QAAQ;YACb,IAAI,QAAQ,EAAE;gBAIZ,qBAAS,CAAC,QAAQ,CAAC,QAAQ,CAAC,CAAC,CAAC,SAAS,CACrC,6CAAwB,CACtB,UAAU,EAEV,SAAS,EAET;oBACE,SAAS,GAAG,KAAK,CAAC;oBAClB,UAAU,CAAC,QAAQ,EAAE,CAAC;gBACxB,CAAC,EACD,WAAW,CACZ,CACF,CAAC;aACH;iBAAM;gBACL,SAAS,GAAG,KAAK,CAAC;gBAClB,UAAU,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;gBAC1B,UAAU,CAAC,QAAQ,EAAE,CAAC;aACvB;QACH,CAAC,CAAC;aACD,KAAK,CAAC,WAAW,CAAC,CAAC;QAEtB,OAAO;YACL,IAAI,SAAS,EAAE;gBACb,UAAU,CAAC,KAAK,EAAE,CAAC;aACpB;QACH,CAAC,CAAC;IACJ,CAAC,CAAC,CAAC;AACL,CAAC;AArFD,8BAqFC"}
\ No newline at end of file
diff --git a/node_modules/rxjs/dist/cjs/internal/observable/dom/webSocket.js b/node_modules/rxjs/dist/cjs/internal/observable/dom/webSocket.js
deleted file mode 100644
index 449b942..0000000
--- a/node_modules/rxjs/dist/cjs/internal/observable/dom/webSocket.js
+++ /dev/null
@@ -1,9 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.webSocket = void 0;
-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/node_modules/rxjs/dist/cjs/internal/observable/dom/webSocket.js.map b/node_modules/rxjs/dist/cjs/internal/observable/dom/webSocket.js.map
deleted file mode 100644
index 2cb3f6b..0000000
--- a/node_modules/rxjs/dist/cjs/internal/observable/dom/webSocket.js.map
+++ /dev/null
@@ -1 +0,0 @@
-{"version":3,"file":"webSocket.js","sourceRoot":"","sources":["../../../../../src/internal/observable/dom/webSocket.ts"],"names":[],"mappings":";;;AAAA,uDAA8E;AA8J9E,SAAgB,SAAS,CAAI,iBAAqD;IAChF,OAAO,IAAI,mCAAgB,CAAI,iBAAiB,CAAC,CAAC;AACpD,CAAC;AAFD,8BAEC"}
\ No newline at end of file