由于版本的原因 要使用map和filter必须引入
import { map,filter } from 'rxjs/operators'
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);
})