remove dev node_modules (oops)

1 files changed, 0 insertions, 70 deletions

diff --git a/node_modules/rxjs/dist/esm5/internal/operators/windowTime.js b/node_modules/rxjs/dist/esm5/internal/operators/windowTime.js
deleted file mode 100644
index 6c16342..0000000
--- a/node_modules/rxjs/dist/esm5/internal/operators/windowTime.js
+++ /dev/null
@@ -1,70 +0,0 @@
-import { Subject } from '../Subject';
-import { asyncScheduler } from '../scheduler/async';
-import { Subscription } from '../Subscription';
-import { operate } from '../util/lift';
-import { createOperatorSubscriber } from './OperatorSubscriber';
-import { arrRemove } from '../util/arrRemove';
-import { popScheduler } from '../util/args';
-import { executeSchedule } from '../util/executeSchedule';
-export function windowTime(windowTimeSpan) {
-    var _a, _b;
-    var otherArgs = [];
-    for (var _i = 1; _i < arguments.length; _i++) {
-        otherArgs[_i - 1] = arguments[_i];
-    }
-    var scheduler = (_a = popScheduler(otherArgs)) !== null && _a !== void 0 ? _a : asyncScheduler;
-    var windowCreationInterval = (_b = otherArgs[0]) !== null && _b !== void 0 ? _b : null;
-    var maxWindowSize = otherArgs[1] || Infinity;
-    return 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(windowRecords, record);
-            restartOnClose && startWindow();
-        };
-        var startWindow = function () {
-            if (windowRecords) {
-                var subs = new Subscription();
-                subscriber.add(subs);
-                var window_1 = new Subject();
-                var record_1 = {
-                    window: window_1,
-                    subs: subs,
-                    seen: 0,
-                };
-                windowRecords.push(record_1);
-                subscriber.next(window_1.asObservable());
-                executeSchedule(subs, scheduler, function () { return closeWindow(record_1); }, windowTimeSpan);
-            }
-        };
-        if (windowCreationInterval !== null && windowCreationInterval >= 0) {
-            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(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;
-        };
-    });
-}
-//# sourceMappingURL=windowTime.js.map
\ No newline at end of file