1 import { OuterSubscriber } from '../OuterSubscriber';
2 import { subscribeToResult } from '../util/subscribeToResult';
3 export function sample(notifier) {
4 return (source) => source.lift(new SampleOperator(notifier));
7 constructor(notifier) {
8 this.notifier = notifier;
10 call(subscriber, source) {
11 const sampleSubscriber = new SampleSubscriber(subscriber);
12 const subscription = source.subscribe(sampleSubscriber);
13 subscription.add(subscribeToResult(sampleSubscriber, this.notifier));
17 class SampleSubscriber extends OuterSubscriber {
20 this.hasValue = false;
26 notifyNext(outerValue, innerValue, outerIndex, innerIndex, innerSub) {
34 this.hasValue = false;
35 this.destination.next(this.value);
39 //# sourceMappingURL=sample.js.map