RxJS Observables in Angular
From the Angular cheat sheet · HTTP & Observables · verified Jul 2026
RxJS Observables
Working with observables and operators
typescript
// Creating observables
const obs$ = new Observable(observer => {
observer.next('Hello');
observer.next('World');
observer.complete();
});
// Subscribe
const subscription = obs$.subscribe({
next: value => console.log(value),
error: err => console.error(err),
complete: () => console.log('Complete')
});
// Unsubscribe
subscription.unsubscribe();💡 Use appropriate flattening operator (switchMap for searches)
⚡ takeUntil pattern prevents memory leaks
📌 BehaviorSubject for state management
🔥 shareReplay for caching HTTP requests