1 files changed, 0 insertions, 33 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/operators/bufferToggle.js b/node_modules/rxjs/dist/esm/internal/operators/bufferToggle.js
deleted file mode 100644
index dfefe4a..0000000
--- a/node_modules/rxjs/dist/esm/internal/operators/bufferToggle.js
+++ /dev/null
@@ -1,33 +0,0 @@
-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 bufferToggle(openings, closingSelector) {
-    return operate((source, subscriber) => {
-        const buffers = [];
-        innerFrom(openings).subscribe(createOperatorSubscriber(subscriber, (openValue) => {
-            const buffer = [];
-            buffers.push(buffer);
-            const closingSubscription = new Subscription();
-            const emitBuffer = () => {
-                arrRemove(buffers, buffer);
-                subscriber.next(buffer);
-                closingSubscription.unsubscribe();
-            };
-            closingSubscription.add(innerFrom(closingSelector(openValue)).subscribe(createOperatorSubscriber(subscriber, emitBuffer, noop)));
-        }, noop));
-        source.subscribe(createOperatorSubscriber(subscriber, (value) => {
-            for (const buffer of buffers) {
-                buffer.push(value);
-            }
-        }, () => {
-            while (buffers.length > 0) {
-                subscriber.next(buffers.shift());
-            }
-            subscriber.complete();
-        }));
-    });
-}
-//# sourceMappingURL=bufferToggle.js.map
-\ No newline at end of file