今天学习一个RxJs的示例代码。通过代码了解其核心概念：observable对象。可观察对象，也叫发布者。
RxJs核心概念
image.png
发布者对象的onsubscibe函数
发布者对象有个onsubscibe函数，这个函数描述发布者如何向订阅者（观察者）提供服务。这个onsubscibe接受观察者作为参数。
import {observable} from 'rxjs/Observable';
const onSubscribe = observer => {
observer.next(1); //观察者调用自己的next函数，处理发布者提供的数据（就是1）。
observer.next(2);
observer.next(3);
}
image.png
创建发布者对象
发布者对象的创建，需要订阅函数作为构造器参数。
const source$ = new Observable(onSubscribe)
创建观察者对象
const theObserver = {
next:item=>console.log(item);
}
发布者调用subscribe函数，为自己绑定订阅者
source$.subscribe(theObserver);
网友评论