转载

学习 Promise （结合 RxJava）

当前的问题

在开发过程中不同的语言都有遇到 callback hell（回调地狱），回调一般出现在异步操作中。

简单的例子:

① 从网络获取图片

② 将图片进行压缩

③ 压缩后的数据保存到本地

以上几个操作都属于异步操作，

op1(callback(){
    success(){
        op2(callback(){
            success(){
                op3(callback(){
                    success(){ 
                     // done
                    }
                    error(e){
                    }
                })  
            }
            error(e){
            }
        })
    }
    error(e){
    }
})

解决方案

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

Rxjava ：java 中处理异步

Promise ： JavaScript 中处理异步

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

op1()
  .then(op2)
  .then(op3)
  .catch(e)
  .done();

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

创建 promise

rxjava

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

var promise = new Promise(function(resolve, reject) {
  // ... some code
  if (/* 异步操作成功 */){
    resolve(value);
  } else {
    reject(error);
  }
});

流水线

rxjava

observable.doOnNext()
    .map
    .filter
    .doOnNext()
    .subscribe(
        public void onCompleted() {
            // ....               
        }
     
        public void onError(Throwable e) {
            // ...
        }
        
        public void onNext(AppInfo appInfo) {
            // ...
        }
    );

promise

promise.then(function(){

}).then(function(){

}).catch(function(error){

});

all

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

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

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

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

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

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

finally

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

参考链接

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

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

文章来自：http://hanks.xyz

原文 http://hanks.xyz/2016/06/26/promise-by-rx/

正文到此结束

所属分类：编程技术

本文标签： 数据开发 map 参数 cat value 实例 JavaScript https HTML 文章 git App ACE ip 代码 http java IDE final
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

学习 Promise （结合 RxJava）

当前的问题

解决方案

创建 promise

流水线

all

race

finally

参考链接

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流