script
import { of } from 'rxjs';
const observable = of(1, 2, 3);
observable.subscribe(value => console.log(value));
1
2
3
script
import { from } from 'rxjs';
const array = [1, 2, 3];
const observable = from(array);
observable.subscribe(value => console.log(value));
1
2
3
script
import { interval } from 'rxjs';
const observable = interval(1000);
observable.subscribe(value => console.log(value));
0
1
2
...
script
import { of } from 'rxjs';
import { map } from 'rxjs/operators';
const observable = of(1, 2, 3);
observable.pipe(
map(value => value + 1)
).subscribe(value => console.log(value));
2
3
4
script
import { of } from 'rxjs';
import { filter } from 'rxjs/operators';
const observable = of(1, 2, 3, 4, 5);
observable.pipe(
filter(value => value % 2 === 0)
).subscribe(value => console.log(value));
2
4
script
import { fromEvent } from 'rxjs';
import { mergeMap } from 'rxjs/operators';
const button = document.getElementById('button');
const clicks = fromEvent(button, 'click');
clicks.pipe(
mergeMap(event => from(fetch('https://api.example.com/data')))
).subscribe(response => console.log(response));
shell
npm install rxjs
script
import { of, from } from 'rxjs';
import { map, filter, mergeMap } from 'rxjs/operators';
