由于版本的原因 要使用map和filter必须引入

  1. import { map,filter } from 'rxjs/operators'
  2. let streemNum = this.request.getRxjsIntervalDnum()

1 filter的使用

streemNum.pipe(
        filter(value=>{
          if(value%2==0){
            return value
          }
        })
      )
      .subscribe((data)=>{
        console.log(data);
      })

2 map的使用

streemNum.pipe(
        map(value=>{
          return value*value
        })
      ).subscribe((data)=>{

        console.log(data);

      })

3 filter和map的混合使用

streemNum.pipe(
        filter(value=>{
          if(value%2==0){
            return value
          }
        }),
        map(value=>{
          return value**2
        })
      )
      .subscribe((data)=>{
        console.log(data);
      })