typescript
import { fromEvent } from 'rxjs';
import { throttleTime, map } from 'rxjs/operators';
const button = document.getElementById('myButton');
const clickStream = fromEvent(button, 'click');
clickStream.pipe(
throttleTime(1000),
map(event => event.target)
).subscribe(target => {
console.log(`Button ${target.id} clicked!`);
});
typescript
import { ajax } from 'rxjs/ajax';
import { map } from 'rxjs/operators';
ajax.get('/api/data').pipe(
map(response => response.response)
).subscribe(data => {
console.log('Received data:', data);
});
