blob: 8e47b0daa2e77005326c742b5ce47f01efc229a5 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
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((source, subscriber) => {
let buffer = null;
let closingSubscriber = null;
const openBuffer = () => {
closingSubscriber === null || closingSubscriber === void 0 ? void 0 : closingSubscriber.unsubscribe();
const b = buffer;
buffer = [];
b && subscriber.next(b);
innerFrom(closingSelector()).subscribe((closingSubscriber = createOperatorSubscriber(subscriber, openBuffer, noop)));
};
openBuffer();
source.subscribe(createOperatorSubscriber(subscriber, (value) => buffer === null || buffer === void 0 ? void 0 : buffer.push(value), () => {
buffer && subscriber.next(buffer);
subscriber.complete();
}, undefined, () => (buffer = closingSubscriber = null)));
});
}
//# sourceMappingURL=bufferWhen.js.map
|
