ngOnInit() { // produces a number every one second const numbers$ = of(1,2,3,4,5) numbers$.pipe( filter(x => x > 2) ) .subscribe(x => console.log(x); ) // output - 3,4,5 }