mapTo.js
579 Bytes
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