remove dev node_modules (oops)

1 files changed, 0 insertions, 74 deletions

diff --git a/node_modules/rxjs/dist/cjs/internal/operators/windowTime.js b/node_modules/rxjs/dist/cjs/internal/operators/windowTime.js
deleted file mode 100644
index ba43677..0000000
--- a/node_modules/rxjs/dist/cjs/internal/operators/windowTime.js
+++ /dev/null
@@ -1,74 +0,0 @@
-"use strict";
-Object.defineProperty(exports, "__esModule", { value: true });
-exports.windowTime = void 0;
-var Subject_1 = require("../Subject");
-var async_1 = require("../scheduler/async");
-var Subscription_1 = require("../Subscription");
-var lift_1 = require("../util/lift");
-var OperatorSubscriber_1 = require("./OperatorSubscriber");
-var arrRemove_1 = require("../util/arrRemove");
-var args_1 = require("../util/args");
-var executeSchedule_1 = require("../util/executeSchedule");
-function windowTime(windowTimeSpan) {
-    var _a, _b;
-    var otherArgs = [];
-    for (var _i = 1; _i < arguments.length; _i++) {
-        otherArgs[_i - 1] = arguments[_i];
-    }
-    var scheduler = (_a = args_1.popScheduler(otherArgs)) !== null && _a !== void 0 ? _a : async_1.asyncScheduler;
-    var windowCreationInterval = (_b = otherArgs[0]) !== null && _b !== void 0 ? _b : null;
-    var maxWindowSize = otherArgs[1] || Infinity;
-    return lift_1.operate(function (source, subscriber) {
-        var windowRecords = [];
-        var restartOnClose = false;
-        var closeWindow = function (record) {
-            var window = record.window, subs = record.subs;
-            window.complete();
-            subs.unsubscribe();
-            arrRemove_1.arrRemove(windowRecords, record);
-            restartOnClose && startWindow();
-        };
-        var startWindow = function () {
-            if (windowRecords) {
-                var subs = new Subscription_1.Subscription();
-                subscriber.add(subs);
-                var window_1 = new Subject_1.Subject();
-                var record_1 = {
-                    window: window_1,
-                    subs: subs,
-                    seen: 0,
-                };
-                windowRecords.push(record_1);
-                subscriber.next(window_1.asObservable());
-                executeSchedule_1.executeSchedule(subs, scheduler, function () { return closeWindow(record_1); }, windowTimeSpan);
-            }
-        };
-        if (windowCreationInterval !== null && windowCreationInterval >= 0) {
-            executeSchedule_1.executeSchedule(subscriber, scheduler, startWindow, windowCreationInterval, true);
-        }
-        else {
-            restartOnClose = true;
-        }
-        startWindow();
-        var loop = function (cb) { return windowRecords.slice().forEach(cb); };
-        var terminate = function (cb) {
-            loop(function (_a) {
-                var window = _a.window;
-                return cb(window);
-            });
-            cb(subscriber);
-            subscriber.unsubscribe();
-        };
-        source.subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function (value) {
-            loop(function (record) {
-                record.window.next(value);
-                maxWindowSize <= ++record.seen && closeWindow(record);
-            });
-        }, function () { return terminate(function (consumer) { return consumer.complete(); }); }, function (err) { return terminate(function (consumer) { return consumer.error(err); }); }));
-        return function () {
-            windowRecords = null;
-        };
-    });
-}
-exports.windowTime = windowTime;
-//# sourceMappingURL=windowTime.js.map
\ No newline at end of file