1 import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
2 export function sample(notifier) {
3 return (source) => source.lift(new SampleOperator(notifier));
6 constructor(notifier) {
7 this.notifier = notifier;
9 call(subscriber, source) {
10 const sampleSubscriber = new SampleSubscriber(subscriber);
11 const subscription = source.subscribe(sampleSubscriber);
12 subscription.add(innerSubscribe(this.notifier, new SimpleInnerSubscriber(sampleSubscriber)));
16 class SampleSubscriber extends SimpleOuterSubscriber {
19 this.hasValue = false;
33 this.hasValue = false;
34 this.destination.next(this.value);
38 //# sourceMappingURL=sample.js.map