创建一个 Observable ,然后让 Observer,也就是观察者去订阅 Observerable,就是可被观察的对象。
订阅以后,就会执行 Observable,这样它就会把自己里面的数据一个一个地推送给订阅它的 Observer ..
Observer 里面提供了一些方法,决定了怎么样去使用从 Observable 那里交过来的数据 ..
create
下面我们可以先手工去创建一个 Observable ..
先在文件的顶部把 Observable 从 rxjs/Observable 这里导入进来 ..
然后创建一个 observalbe,名字可以是 fruitsObservable .. 用一下导入进来的这个 Observable .. 手工创建一个 observable 可以使用 create 这个操作 ..
它的参数是一个 subscribe 函数 ... 这个函数又接收一个 observer 参数 ..
在 observer 上面应该有三个方法,next,error,还有 complete .. next 方法用来一个一个地传递数据给 observer, error 方法告诉 observer 发生的错误 .. complete 方法让 observer 知道任务已经完成了。
这里先用一下 observer 的 next .. 传递一个苹果 .. 下面再用一下 observer 的 complete 方法 ..
现在我们就已经创建好了一个非常简单的 observable ..