-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
export function debounce(durationSelector) {
return (source) => source.lift(new DebounceOperator(durationSelector));
}
return source.subscribe(new DebounceSubscriber(subscriber, this.durationSelector));
}
}
-class DebounceSubscriber extends OuterSubscriber {
+class DebounceSubscriber extends SimpleOuterSubscriber {
constructor(destination, durationSelector) {
super(destination);
this.durationSelector = durationSelector;
this.hasValue = false;
- this.durationSubscription = null;
}
_next(value) {
try {
subscription.unsubscribe();
this.remove(subscription);
}
- subscription = subscribeToResult(this, duration);
+ subscription = innerSubscribe(duration, new SimpleInnerSubscriber(this));
if (subscription && !subscription.closed) {
this.add(this.durationSubscription = subscription);
}
}
- notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
+ notifyNext() {
this.emitValue();
}
notifyComplete() {
const value = this.value;
const subscription = this.durationSubscription;
if (subscription) {
- this.durationSubscription = null;
+ this.durationSubscription = undefined;
subscription.unsubscribe();
this.remove(subscription);
}
- this.value = null;
+ this.value = undefined;
this.hasValue = false;
super._next(value);
}