继续解惑，异步处理 —— RxJS Observable

这是我参与11月更文挑战的第12天，活动详情查看：2021最后一次更文挑战

接上一篇《Js 异步处理演进，Callback=>Promise=>Observer》，可能不少掘友对 Observer 还心存疑虑，本篇继续解惑~

Observable 称它为可观察对象，它并不是 Angular 的东西，而是 ES7 的一种用来管理异步数据的标准。

Observable 可观察对象是开辟一个连续的通信通道给观察者 Observer，彼此之前形成一种关系，而这种关系需要由 Subscription 来确立，而在整个通道中允许对数据进行转换我们称为操作符 Operator。

有一个形象的比喻：

你订了一个银行卡余额变化短信通知的服务，那么这个时候，每次只要你转账或者是购买商品在使用这张银行卡消费之后，银行的系统就会给你推送一条短信，通知你消费了多少多少钱；

这个场景下，银行卡余额就是 Observable，用户就是 Observer，用户在银行办理这个服务，就是 Subscription，银行卡余额发生转账或购买商品产生了变动，就是 Operator。

将上面的过程转化为代码：

代码语言：javascript复制

import { Observable } from 'rxjs/Rx';

let sub = Observable
    .interval(1000)
    .map(second => second   '秒')
    .subscribe(res => {
        console.log(res);
    });

利用 Observable.interval 每隔 1 秒产生一个数据，然后交给 map 操作号将内容进行转换（银行卡余额发生变动），最后交给观察者打印结果（通知用户余额发生变化）。

如果你想取消这个服务，可以调用 sub.unsubscribe()；

整个过程都在体现一个思想：数据流！这和函数式编程思路一致，数据流就像是工厂流水线，从原材料到成品，经过一层层的处理，所见即所做，非常清晰！（分离材料与加工机器，就是分离 Observable 和 Subscribe）

接下来，我们再具体看看 Observable 细节：

创建

代码语言：javascript复制

const Rx = require('rxjs/Rx')

const myObservable = Rx.Observable.create(observer => {
  observer.next('foo');
  setTimeout(() => observer.next('bar'), 1000);
});

我们可以调用 Observable.create 方法来创建一个 Observable，入参是 observer，在函数内部通过调用 observer.next() 便可生成有一系列值的一个 Observable。

内置方法

代码语言：javascript复制

const observer = {
    next: function(value) {
        console.log(value);
    },
    error: function(error) {
        console.log(error)
    },
    complete: function() {
        console.log('complete')
    }
}

next、error、complete，都是可选项；

打个比方：用户订牛奶厂商的牛奶，牛奶厂商是 Observable，用户是 Observer。用户打电话（subscribe）给牛奶商，牛奶商送牛奶（next），用户收到牛奶后喝牛奶；送奶过程可能发生意外，送奶失败（error）；或者送奶顺利全部完成（complete）；