initial commit: scaffolding

1 files changed, 27 insertions, 0 deletions

diff --git a/node_modules/rxjs/dist/cjs/internal/operators/bufferWhen.js b/node_modules/rxjs/dist/cjs/internal/operators/bufferWhen.js
new file mode 100644
index 0000000..a32e3e6
--- /dev/null
+++ b/node_modules/rxjs/dist/cjs/internal/operators/bufferWhen.js
@@ -0,0 +1,27 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.bufferWhen = void 0;
+var lift_1 = require("../util/lift");
+var noop_1 = require("../util/noop");
+var OperatorSubscriber_1 = require("./OperatorSubscriber");
+var innerFrom_1 = require("../observable/innerFrom");
+function bufferWhen(closingSelector) {
+    return lift_1.operate(function (source, subscriber) {
+        var buffer = null;
+        var closingSubscriber = null;
+        var openBuffer = function () {
+            closingSubscriber === null || closingSubscriber === void 0 ? void 0 : closingSubscriber.unsubscribe();
+            var b = buffer;
+            buffer = [];
+            b && subscriber.next(b);
+            innerFrom_1.innerFrom(closingSelector()).subscribe((closingSubscriber = OperatorSubscriber_1.createOperatorSubscriber(subscriber, openBuffer, noop_1.noop)));
+        };
+        openBuffer();
+        source.subscribe(OperatorSubscriber_1.createOperatorSubscriber(subscriber, function (value) { return buffer === null || buffer === void 0 ? void 0 : buffer.push(value); }, function () {
+            buffer && subscriber.next(buffer);
+            subscriber.complete();
+        }, undefined, function () { return (buffer = closingSubscriber = null); }));
+    });
+}
+exports.bufferWhen = bufferWhen;
+//# sourceMappingURL=bufferWhen.js.map
\ No newline at end of file