1import { Component, OnInit } from '@angular/core';
2import { Observable, of} from 'rxjs';
3import { map, filter, tap } from 'rxjs/operators'
4 
5 
6@Component({
7  selector: 'app-root',
8  templateUrl: './app.component.html',
9  styleUrls: ['./app.component.css']
10})
11export class AppComponent implements OnInit {
12 
13  obs = new Observable((observer) => {
14    observer.next(1)
15    observer.next(2)
16    observer.next(3)
17    observer.next(4)
18    observer.next(5)
19    observer.complete()
20  }).pipe(
21    filter(data => data > 2),                    //filter Operator
22    map((val) => {return val as number * 2}),    //map operator
23  )
24 
25 data = [];
26 
27  ngOnInit() {
28    this.obs1.subscribe(
29      val => {
30        console.log(this.data)
31      }
32    )
33  }
34 
35}