initial commit: scaffolding

1 files changed, 23 insertions, 0 deletions

diff --git a/node_modules/rxjs/dist/esm5/internal/operators/bufferWhen.js b/node_modules/rxjs/dist/esm5/internal/operators/bufferWhen.js
new file mode 100644
index 0000000..019fb52
--- /dev/null
+++ b/node_modules/rxjs/dist/esm5/internal/operators/bufferWhen.js
@@ -0,0 +1,23 @@
+import { operate } from '../util/lift';
+import { noop } from '../util/noop';
+import { createOperatorSubscriber } from './OperatorSubscriber';
+import { innerFrom } from '../observable/innerFrom';
+export function bufferWhen(closingSelector) {
+    return 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(closingSelector()).subscribe((closingSubscriber = createOperatorSubscriber(subscriber, openBuffer, noop)));
+        };
+        openBuffer();
+        source.subscribe(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); }));
+    });
+}
+//# sourceMappingURL=bufferWhen.js.map
\ No newline at end of file