initial commit: scaffolding

1 files changed, 50 insertions, 0 deletions

diff --git a/node_modules/rxjs/dist/cjs/internal/operators/repeatWhen.js b/node_modules/rxjs/dist/cjs/internal/operators/repeatWhen.js
new file mode 100644
index 0000000..e3ca262
--- /dev/null
+++ b/node_modules/rxjs/dist/cjs/internal/operators/repeatWhen.js
@@ -0,0 +1,50 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.repeatWhen = void 0;
+var innerFrom_1 = require("../observable/innerFrom");
+var Subject_1 = require("../Subject");
+var lift_1 = require("../util/lift");
+var OperatorSubscriber_1 = require("./OperatorSubscriber");
+function repeatWhen(notifier) {
+    return lift_1.operate(function (source, subscriber) {
+        var innerSub;
+        var syncResub = false;
+        var completions$;
+        var isNotifierComplete = false;
+        var isMainComplete = false;
+        var checkComplete = function () { return isMainComplete && isNotifierComplete && (subscriber.complete(), true); };
+        var getCompletionSubject = function () {
+            if (!completions$) {
+                completions$ = new Subject_1.Subject();
+                innerFrom_1.innerFrom(notifier(completions$)).subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function () {
+                    if (innerSub) {
+                        subscribeForRepeatWhen();
+                    }
+                    else {
+                        syncResub = true;
+                    }
+                }, function () {
+                    isNotifierComplete = true;
+                    checkComplete();
+                }));
+            }
+            return completions$;
+        };
+        var subscribeForRepeatWhen = function () {
+            isMainComplete = false;
+            innerSub = source.subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, undefined, function () {
+                isMainComplete = true;
+                !checkComplete() && getCompletionSubject().next();
+            }));
+            if (syncResub) {
+                innerSub.unsubscribe();
+                innerSub = null;
+                syncResub = false;
+                subscribeForRepeatWhen();
+            }
+        };
+        subscribeForRepeatWhen();
+    });
+}
+exports.repeatWhen = repeatWhen;
+//# sourceMappingURL=repeatWhen.js.map
\ No newline at end of file