// RxJS v6+import { fromEvent } from'rxjs';import { mapTo } from'rxjs/operators';//emit every click on documentconstsource=fromEvent(document,'click');//map all emissions to one valueconstexample=source.pipe(mapTo('GOODBYE WORLD!'));//output: (click)'GOODBYE WORLD!'...constsubscribe=example.subscribe(val =>console.log(val));
// RxJS v6+import { interval } from'rxjs';import { mapTo } from'rxjs/operators';//emit value every two secondsconstsource=interval(2000);//map all emissions to one valueconstexample=source.pipe(mapTo('HELLO WORLD!'));//output: 'HELLO WORLD!'...'HELLO WORLD!'...'HELLO WORLD!'...constsubscribe=example.subscribe(val =>console.log(val));