The pipe method of the Angular Observable is used to chain multiple operators together. We can use the pipe as a standalone method, which helps us to reuse it at multiple places or as an instance method. In this tutorial, we will take a look at the pipe and learn how to use it in an Angular Application. We will show you examples of pipe using map, filter & tap operators.
Table of Contents
RxJs Operators
The operators are very important components of the Rxjs library. They are functions that take an observable as input and transform it into a new observable and return it. We use them to manipulate the observable data stream.
For Example.
Map operator applies a given project function to each value emitted by the source Observable and emits the resulting values as an Observable.
Filter operator filter items from the source observable based on some condition and returns the filtered value as a new observable
The following table lists some of the commonly used operators
| AREA | OPERATORS |
|---|---|
| Combination | combineLatest, concat, merge, startWith , withLatestFrom, zip |
| Filtering | debounceTime, distinctUntilChanged, filter, take, takeUntil, takeWhile, takeLast, first, last, single, skip, skipUntil, skipWhile, skipLast, |
| Transformation | bufferTime, concatMap, map, mergeMap, scan, switchMap, ExhaustMap, reduce |
| Utility | tap, delay, delaywhen |
| Error Handling | throwerror, catcherror, retry, retrywhen |
| Multicasting | share |
Using pipe to combine operators
The pipe method accepts operators such as filter, map, as arguments. Each argument must be separated by a comma. The order of the operators is important because when a user subscribes to an observable, the pipe executes the operators in a sequence in which they are added.
There are two ways we can use the pipe. One as an instance of observable and the other way is to use if as standalone method
To use observable we need it to import from the rxjs library. If you are intend to use the pipe standalone function, then you also need to import it as well. All the operators are available in the library rxjs/operators.
1 2 3 4 | import { Observable, of, pipe} from 'rxjs'; import { map, filter, tap } from 'rxjs/operators' |
Pipe as an instance method
The pipe as an instance method is used as below. We the operators op1, op2 etc are passed as the argument to pipe method. The output of op1 method becomes input of the op2 operator and so forth.
1 2 3 4 5 6 7 8 | obs.pipe( op1(), op2(), op3(), op3(), ) |
Example : Pipe with Map, Filter & Tap
Here is the example of using pipe with map & filter operator.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 | import { Component, OnInit } from '@angular/core'; import { Observable, of} from 'rxjs'; import { map, filter, tap } from 'rxjs/operators' @Component({ selector: 'app-root', templateUrl: './app.component.html', styleUrls: ['./app.component.css'] }) export class AppComponent implements OnInit { obs = new Observable((observer) => { observer.next(1) observer.next(2) observer.next(3) observer.next(4) observer.next(5) observer.complete() }).pipe( filter(data => data > 2), //filter Operator map((val) => {return val as number * 2}), //map operator ) data = []; ngOnInit() { this.obs1.subscribe( val => { console.log(this.data) } ) } } //result [6, 8, 10] |
The following example makes use of pipe with map, filter & tap operator. The tap operator returns a new observable which is a mirror copy of the source observable. We use it mostly for debugging purposes ( for example for logging the values of observable as shown below).
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 | import { Component, OnInit } from '@angular/core'; import { Observable, of, pipe } from 'rxjs'; import { map, filter, tap } from 'rxjs/operators' @Component({ selector: 'app-root', templateUrl: './app.component.html', styleUrls: ['./app.component.css'] }) export class AppComponent implements OnInit { obs = new Observable((observer) => { observer.next(1) observer.next(2) observer.next(3) observer.next(4) observer.next(5) observer.complete() }).pipe( tap(data => console.log('tap '+data)), //tap filter(data => data > 2), //filter tap(data => console.log('filter '+data)), //tap map((val) => { return val as number * 2 }), //map tap(data => console.log('final '+data)), //tap ) data = []; ngOnInit() { this.obs.subscribe( val => { this.data.push(val) console.log(this.data) } ) } } |
Pipe as stand alone method
We can also use the pipe as a standalone function to compose operators and re use the pipe at other places.
Example
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 | import { Component, OnInit } from '@angular/core'; import { Observable, of, pipe } from 'rxjs'; import { map, filter, tap } from 'rxjs/operators' @Component({ selector: 'app-root', templateUrl: './app.component.html', styleUrls: ['./app.component.css'] }) export class AppComponent implements OnInit { customOperator = pipe( tap(data => console.log('tap '+data)), filter(data => data > 2), tap(data => console.log('filter '+data)), map((val) => { return val as number * 2 }), tap(data => console.log('final '+data)), ); obs = new Observable((observer) => { observer.next(1) observer.next(2) observer.next(3) observer.next(4) observer.next(5) observer.complete() }).pipe( this.customOperator, tap(data => console.log('final '+data)), ) data = []; ngOnInit() { this.obs.subscribe( val => { this.data.push(val) console.log(this.data) } ) } } |
You can also use the stand alone pipe as shown below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 | customOperator = pipe( tap(data => console.log('tap '+data)), filter(data => data > 2), tap(data => console.log('filter '+data)), map((val) => { return val as number * 2 }), tap(data => console.log('final '+data)), ); obs = new Observable((observer) => { observer.next(1) observer.next(2) observer.next(3) observer.next(4) observer.next(5) observer.complete() }) ngOnInit() { this.customOperator(this.obs).subscribe(); } |
References
- RxJs Library
- Operators
- Pipe API
- Map API
- Tap API
- Filter API
Great post! The example you provided on using Angular observable pipe clarified a lot of my questions. I particularly liked the way you explained the transformation of data, making it easier to understand. Looking forward to more tutorials like this!
Thank you for the detailed explanation on using Angular’s observable pipe! The example you provided was clear and easy to follow. I especially appreciated how you broke down the different operators and their use cases. Looking forward to applying this in my projects!
Great explanation of using the observable pipe in Angular! The example you provided was very clear and helped me understand how to manage asynchronous data more effectively in my application. Thanks for sharing such useful insights!
pls take the website to dark mode
Very well written. thank you
Very well written. thanks a lot
Great explanation. Thanks!
I think it’s one of the best articles I’ve ever read about the rxjs methods. Easy to understand.
Thank you!
It’s really well explained in simple English. Thanks a lot. God bless you and keep it up.
This website is awesome. I have been searching for this information for long. All the answers that I got are confusing and pure theoretical which is very hard to understand. This website is giving easy answers for the complicated angular questions. Much appreciated.
Very well written. If you could cover the error handling like a real case in industry, it would be perfect.