1 import { Subscriber } from '../Subscriber';
2 export function defaultIfEmpty(defaultValue = null) {
3 return (source) => source.lift(new DefaultIfEmptyOperator(defaultValue));
5 class DefaultIfEmptyOperator {
6 constructor(defaultValue) {
7 this.defaultValue = defaultValue;
9 call(subscriber, source) {
10 return source.subscribe(new DefaultIfEmptySubscriber(subscriber, this.defaultValue));
13 class DefaultIfEmptySubscriber extends Subscriber {
14 constructor(destination, defaultValue) {
16 this.defaultValue = defaultValue;
21 this.destination.next(value);
25 this.destination.next(this.defaultValue);
27 this.destination.complete();
30 //# sourceMappingURL=defaultIfEmpty.js.map