initial commit: scaffolding

1 files changed, 54 insertions, 0 deletions

diff --git a/node_modules/rxjs/dist/esm/internal/operators/windowToggle.js b/node_modules/rxjs/dist/esm/internal/operators/windowToggle.js
new file mode 100644
index 0000000..d7c27fb
--- /dev/null
+++ b/node_modules/rxjs/dist/esm/internal/operators/windowToggle.js
@@ -0,0 +1,54 @@
+import { Subject } from '../Subject';
+import { Subscription } from '../Subscription';
+import { operate } from '../util/lift';
+import { innerFrom } from '../observable/innerFrom';
+import { createOperatorSubscriber } from './OperatorSubscriber';
+import { noop } from '../util/noop';
+import { arrRemove } from '../util/arrRemove';
+export function windowToggle(openings, closingSelector) {
+    return operate((source, subscriber) => {
+        const windows = [];
+        const handleError = (err) => {
+            while (0 < windows.length) {
+                windows.shift().error(err);
+            }
+            subscriber.error(err);
+        };
+        innerFrom(openings).subscribe(createOperatorSubscriber(subscriber, (openValue) => {
+            const window = new Subject();
+            windows.push(window);
+            const closingSubscription = new Subscription();
+            const closeWindow = () => {
+                arrRemove(windows, window);
+                window.complete();
+                closingSubscription.unsubscribe();
+            };
+            let closingNotifier;
+            try {
+                closingNotifier = innerFrom(closingSelector(openValue));
+            }
+            catch (err) {
+                handleError(err);
+                return;
+            }
+            subscriber.next(window.asObservable());
+            closingSubscription.add(closingNotifier.subscribe(createOperatorSubscriber(subscriber, closeWindow, noop, handleError)));
+        }, noop));
+        source.subscribe(createOperatorSubscriber(subscriber, (value) => {
+            const windowsCopy = windows.slice();
+            for (const window of windowsCopy) {
+                window.next(value);
+            }
+        }, () => {
+            while (0 < windows.length) {
+                windows.shift().complete();
+            }
+            subscriber.complete();
+        }, handleError, () => {
+            while (0 < windows.length) {
+                windows.shift().unsubscribe();
+            }
+        }));
+    });
+}
+//# sourceMappingURL=windowToggle.js.map
\ No newline at end of file