import { Subscriber } from '../Subscriber'; | |
export function mapTo(value) { | |
return (source) => source.lift(new MapToOperator(value)); | |
} | |
class MapToOperator { | |
constructor(value) { | |
this.value = value; | |
} | |
call(subscriber, source) { | |
return source.subscribe(new MapToSubscriber(subscriber, this.value)); | |
} | |
} | |
class MapToSubscriber extends Subscriber { | |
constructor(destination, value) { | |
super(destination); | |
this.value = value; | |
} | |
_next(x) { | |
this.destination.next(this.value); | |
} | |
} | |
//# sourceMappingURL=mapTo.js.map |