学习 Promise （结合 RxJava）

Promisse 解决回调嵌套问题。

当前的问题

在开发过程中不同的语言都有遇到 callback hell（回调地狱）， 回调一般出现在异步操作中。
简单的例子:
① 从网络获取图片
② 将图片进行压缩
③ 压缩后的数据保存到本地
以上几个操作都属于异步操作，

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
op1(callback(){
    success(){
        op2(callback(){
            success(){
                op3(callback(){
                    success(){
                     // done
                    }
                    error(e){
                    }
                })
            }
            error(e){
            }
        })
    }
    error(e){
    }
})

解决方案

不同语言设计针对此都有对应的解决方案，将回调写成流水线，将复杂的操作变成一条线。

Rxjava：java 中处理异步

Promise： JavaScript 中处理异步

写起来类似于下面的代码：

1
2
3
4
5
op1()
  .then(op2)
  .then(op3)
  .catch(e)
  .done();

Promise 对象代表一个异步操作，有三种状态：Pending（进行中）、Resolved（已完成，又称Fulfilled）和 Rejected（已失败）。

创建 promise

rxjava

1
2
3
4
5
6
7
8
9
10
11
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
      // ... some code
      if (/* 异步操作成功 */){
        subscriber.onNext(value);
        subscriber.onCompleted();
      } else {
        subscriber.onError(error);
      }
});

Promise

1
2
3
4
5
6
7
8
var promise = new Promise(function(resolve, reject) {
  // ... some code
  if (/* 异步操作成功 */){
    resolve(value);
  } else {
    reject(error);
  }
});

流水线

rxjava

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
observable.doOnNext()
    .map
    .filter
    .doOnNext()
    .subscribe(
        public void onCompleted() {
            // ....
        }

        public void onError(Throwable e) {
            // ...
        }

        public void onNext(AppInfo appInfo) {
            // ...
        }
    );

promise

1
2
3
4
5
6
7
promise.then(function(){

}).then(function(){

}).catch(function(error){

});

all

类似于 Observable ob = Observable.merge(ob1,ob2,ob3)

Promise.all方法用于将多个Promise实例，包装成一个新的Promise实例。

1
var p = Promise.all([p1, p2, p3]);

上面代码中，Promise.all 方法接受一个数组作为参数，p1、p2、p3 都是Promise对象的实例。（Promise.all方法的参数可以不是数组，但必须具有Iterator接口，且返回的每个成员都是Promise实例。）

p的状态由p1、p2、p3决定，分成两种情况。

（1）只有p1、p2、p3的状态都变成fulfilled，p的状态才会变成fulfilled，此时p1、p2、p3的返回值组成一个数组，传递给p的回调函数。

（2）只要p1、p2、p3之中有一个被rejected，p的状态就变成rejected，此时第一个被reject的实例的返回值，会传递给p的回调函数。

race

1
var p = Promise.race([p1,p2,p3]);

Promise.race 方法同样是将多个Promise实例，包装成一个新的Promise实例。

上面代码中，只要p1、p2、p3之中有一个实例率先改变状态，p的状态就跟着改变。那个率先改变的Promise实例的返回值，就传递给p的回调函数。

finally

不管 Promise 对象最后状态如何，都会执行的操作 。

参考链接

https://es6.ruanyifeng.com/?search=fetch&x=0&y=0#docs/promise

https://mcxiaoke.gitbooks.io/rxdocs/content/operators/Merge.html