1 import { Subscription } from '../Subscription';
2 import { OuterSubscriber } from '../OuterSubscriber';
3 import { subscribeToResult } from '../util/subscribeToResult';
4 export function bufferWhen(closingSelector) {
5 return function (source) {
6 return source.lift(new BufferWhenOperator(closingSelector));
9 class BufferWhenOperator {
10 constructor(closingSelector) {
11 this.closingSelector = closingSelector;
13 call(subscriber, source) {
14 return source.subscribe(new BufferWhenSubscriber(subscriber, this.closingSelector));
17 class BufferWhenSubscriber extends OuterSubscriber {
18 constructor(destination, closingSelector) {
20 this.closingSelector = closingSelector;
21 this.subscribing = false;
25 this.buffer.push(value);
28 const buffer = this.buffer;
30 this.destination.next(buffer);
36 this.subscribing = false;
38 notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
42 if (this.subscribing) {
50 let { closingSubscription } = this;
51 if (closingSubscription) {
52 this.remove(closingSubscription);
53 closingSubscription.unsubscribe();
55 const buffer = this.buffer;
57 this.destination.next(buffer);
62 const { closingSelector } = this;
63 closingNotifier = closingSelector();
66 return this.error(err);
68 closingSubscription = new Subscription();
69 this.closingSubscription = closingSubscription;
70 this.add(closingSubscription);
71 this.subscribing = true;
72 closingSubscription.add(subscribeToResult(this, closingNotifier));
73 this.subscribing = false;
76 //# sourceMappingURL=bufferWhen.js.map