[译]RxJS文档04——Observer 观察者

xiaolinbang 发布于2019-08-20 17:30 / 771人阅读

摘要：原文什么是观察者是流推送数据的用户。观察者们就是一组函数的集合，监听着每一个流推送出的不同类型的通知，包括和。如果没有为某个类型的通知提供，流的执行过程仍然会照常进行，但是响应的通知将会被忽略，因为观察者没有提供相应的来接收。

原文: http://reactivex.io/rxjs/manu...

什么是Observer？ 观察者(Observer)是Observable流推送数据的用户。观察者们(Observers)就是一组callback函数的集合，监听着每一个Observable流推送出的不同类型的通知，包括:next,error和complete。

以下是一个经典的观察者对象:

var observer = {
  next: x => console.log("Observer got a next value: " + x),
  error: err => console.error("Observer got an error: " + err),
  complete: () => console.log("Observer got a complete notification"),
};

为了使用观察者，需要让他订阅一个Observable流：

observable.subscribe(observer);

观察者是一个包含三个回调函数的对象，每一个函数都时刻准备接收来自Observable流推送的不同消息。

Observer在RxJS中是被优待的。如果没有为某个类型的通知提供callback，Observable流的执行过程仍然会照常进行，但是响应的通知将会被忽略，因为观察者没有提供相应的callback来接收。

下面是一个Observer没有提供complete响应(callback)的例子：

var observer = {
  next: x => console.log("Observer got a next value: " + x),
  error: err => console.error("Observer got an error: " + err),
};

订阅一个Observable流的时候，你也可以只提供一个callback函数作为参数，而不用完整提供一个包含三个回调的对象，就像下面的例子:

observable.subscribe(x => console.log("Observer got a next value: " + x));

在observable.subscribe()内部，将会创建一个观察者对象(Observer object)，并将第一个参数提供的callback作为next通知的响应函数。接受三个类型通知的callback也可以分别以参数的形式提供:

observable.subscribe(
  x => console.log("Observer got a next value: " + x),
  err => console.error("Observer got an error: " + err),
  () => console.log("Observer got a complete notification")
);

私有云服务器托管 Observer RxJS 引入rxjs Rxjs_Subject

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/83627.html

[译]RxJS文档03——剖析Observable

摘要：通过执行和可以向订阅者推送不同的通知。之后，执行过程可能被处理掉。当调用并得到观察者时，在中传入的函数将会被执行。每次执行都会触发一个单独针对当前的运行逻辑。通知不发出任何值，表示流的结束。原文:http://reactivex.io/rxjs/manu... Rx.Observalbe.create()或者创建操作符，可以创建（created） Observable流。Obser...

netScorpion 2019-08-20 17:30 评论0 收藏0
[译] RxJS文档02—— Observable 可观察量

摘要：原文可观察量是一种能惰性推送的集合，他可以包含多个值。是一种惰性计算方式，会在迭代中同步的返回到无限个可能的话返回值。使用一种处理方法，最终可能会或可能不会返回一个值。无论是同步方式还是异步方式，都可以择其一来传递返回值。原文：http://reactivex.io/rxjs/manu... Observable 可观察量是一种能惰性推送的集合，他可以包含多个值。下面的表格对比了推送...

A Loity 2019-08-20 17:30 评论0 收藏0
[译]RxJS文档01——介绍

摘要：原文是一个使用可观察量队列解决异步编程和基于事件编程的库。提供了几个管理异步事件的核心概念可观察量，代表了一个由未来获取到的值或事件组成的集合。相当于事件触发器，是向多个广播事件或推送值的唯一方法。原文:http://reactivex.io/rxjs/manu... RxJS 是一个使用可观察量(observable)队列解决异步编程和基于事件编程的js库。他提供了一个核心的类型O...

BlackHole1 2019-08-20 17:30 评论0 收藏0
[译]RxJS06——Subject

摘要：举例来说，每年都有生日是一道数据流，但是一个人的年龄却是一个流。运行结果显示，第二个在订阅之后，获得了数据流中最后毫秒事件内产生的和三个值。原文:http://reactivex.io/rxjs/manu... Subject是什么？ RxJS的Subject是Observable的一个特殊类型，他可以将流中的值广播给众多观察者(Observer)。一般的Observalbe流是单一...

gitmilk 2019-08-20 17:29 评论0 收藏0
将RxJS融入React项目

摘要：技术积累经过社区的努力学习资料还是很多的，官方中文文档就已经很不错，不过我们先从天精通初步感受一下然后配合一些中文文档来补充知识点，最后再根据官方文档来校验整个知识体系。资料学习操作符的时候可以对照弹珠图的交互弹珠图的中文版中文文档前言最近准备毕设，技术选型的时候因为功能的一些需求准备将RxJs融入到项目中，考虑RxJs的时候因为之前的技术栈还犹豫了一下，查了一些资料以及粗略浏览了...

frontoldman 2019-08-26 11:37 评论0 收藏0