We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
liftedSource
source
1 parent 9d44143 commit f73e056Copy full SHA for f73e056
src/internal/operators/bufferToggle.ts
@@ -56,7 +56,7 @@ export function bufferToggle<T, O>(
56
openings: SubscribableOrPromise<O>,
57
closingSelector: (value: O) => SubscribableOrPromise<any>
58
): OperatorFunction<T, T[]> {
59
- return operate((liftedSource, subscriber) => {
+ return operate((source, subscriber) => {
60
const buffers: T[][] = [];
61
62
// Subscribe to the openings notifier first
@@ -87,7 +87,7 @@ export function bufferToggle<T, O>(
87
)
88
);
89
90
- liftedSource.subscribe(
+ source.subscribe(
91
new OperatorSubscriber(
92
subscriber,
93
(value) => {
0 commit comments