npm install rxjs
yarn add rxjs
script
import { Observable } from 'rxjs';
const myObservable = new Observable(observer => {
observer.next('Hello');
observer.next('World');
observer.complete();
});
script
myObservable.subscribe({
next: value => console.log(value),
complete: () => console.log('Complete')
});
script
import { Observable } from 'rxjs';
import { map } from 'rxjs/operators';
const myObservable = new Observable(observer => {
observer.next(1);
observer.next(2);
observer.complete();
});
myObservable.pipe(
map(value => value * 2)
).subscribe({
next: value => console.log(value),
complete: () => console.log('Complete')
});
script
const subscription = myObservable.subscribe(...);
subscription.unsubscribe();
