RxJS
处理数据流
管道
1 在项目中使用
import {Observable} from 'rxjs/Observable';
import 'rxjs/add/operator/map';
title = 'aspp';
using(){
// 定义数据源
let onSubscribe = (observer)=>{
observer.next(1);
observer.next(2);
observer.next(3);
}
// 数据源
const source$ = Observable.create(onSubscribe);
// 对每一个数据，进行操作
source$.map((item)=>{
return item +1;
}).subscribe((res)=>{console.log(res)});
}
constructor(){
this.using();
}
运行效果：
image.png
