Promise周边方法

上面了解promise a+之后，那么这篇文章就是扩展一下promise的周边方法

promisify的实现

promisify是node提供的一个方法用来解决回调嵌套问题，用起来很方便;我项目中有两个文件，一个为name.txt,里面存放的是age.txt，另一个为age.txt里面的内容为18，这里就是为了演示多个异步接收返回值问题，现在让我们看看原来获取异步返回值，毫无疑问这样非常的恶心

原始调用异步

let fs= require('fs');
fs.readFile('./name.txt', 'utf8', function (err, data) {
    console.log(data);//age.txt
    if (err) {
        console.log(err);
    } else {
        fs.readFile(data, 'utf8', function (err, data) {
            if (err) {
                console.log(err);
            } else {
                console.log(data);
            }
        })
    }

});

既然已经看到他的恶心之处了，那我们想办法优化一下，封装一个公共函数：

read公共方法的封装

function read(...args) {
    let dfd = Promise.defer();//这个是我们上一账封装的promise中的方法
    fs.readFile(...args, function (err, data) {
        if (err) dfd.reject(err);
        dfd.resolve(data)
    });
    return dfd.promise
}

使用的时候如下：

read('./name.txt', 'utf8').then(data => {
    console.log(data);
    return read(data, 'utf8')
}).then(data => {
    console.log(data);
})

上面这种看起来不错，但是还是不能让人满意，因为他的功能太单一了，这时候我们的主角promisify就上场了，那么我们先来看一看它原本是怎么用的：

promisify使用

let {promisify} = require('util');//node提供的方法库
let readFile = promisify(fs.readFile); //用什么方法就把对应的方法传进去，肥肠的方便

readFile('./name.txt', 'utf8').then(data => {
    console.log(data);//age.txt
    return readFile(data, 'utf8')
}).then(data => {
    console.log(data);//18
})

promisify实现

上面的用法很简单，那么我们简单的实现一下吧,用法和以上相同

function promisify(fn) {//你传进来的方法fs.readFile/fs.writeFile...
    return function (...args) {//传进来的路径，格式
        //既然有then那么他就是一个promise
        return new Promise((resolve, reject) => {
            fn(...args,function (err,data) {
                if(err) reject(err)
                resolve(data)
            })
        })
    }
}

promise.all实现

promise.all方法传入一个数组，最后按顺序返回一个数组，如果数组中其中一项为失败那么就是失败态
用法：

Promise.all([1, readFile('./name.txt', 'utf8'), 2, readFile('./age.txt', 'utf8'), 3]).then(data => {
    console.log(data); //[1,'age.txt'(name中写的内容),2,'18'(age中写的内容),3]
});

实现：

//校验传进来的值是不是promise，是返回true，否则返回false
function isPromise(x) {
    if((typeof x==='object'&&x!=null)||typeof x ==='function'){
        if(typeof  x.then ==='function'){
            return true
        }
    }
    return false
}

Promise.all = function (arr) {
      //返回一个promise
    return new Promise((resolve, reject) => {
        let ary = [];
        //用来记录返回数组的长度
        let idx=0;
        let insertAry=(value,index)=>{
            ary[index]=value;
            if(++idx===arr.length){
                resolve(ary)
            }
        };
       //循环传入的数组
        for (let i = 0; i < arr.length; i++) {
            let currentValue = arr[i];
            if (isPromise(currentValue)) {
            //如果是promise
                currentValue.then(y=>{
                    insertAry(y,i)
                },reject)
            } else {
            //如果是普通值
                insertAry(currentValue,i)
            }
        }
    })
};

直接调用promise.reslove和promise.reject

用法：

Promise.resolve(1).then(data=>{console.log(data)})

实现:

Promise.resolve=function(value){
    return new Promise((resolve,reject)=>{
        resolve(value)
    })
};

catch

catch就是一个没有成功参数的then,在上一篇文章封装好的Promise中加入一个catch函数

 catch(fn){//catch接收一个函数
      return  this.then(null,fn)//返回的也是promise
    }

promise中的finally

不管成功还是失败都会执行，并且返回一个promise以供then调用，也是then的另一种执行形式
用法：

Promise.resolve(readFile('./name.txt','utf8')).then(data=>{
    // console.log(data);
    return data
}).catch(err=>{
    console.log(err);
}).finally(data=>{
    console.log('finally');
}).then(data=>{
    console.log(data);
});

实现:
在上篇封装的promise中加入以下方法

finally(callback){

   return this.then(
        res => Promise.resolve(callback()).then(() => res),
        err => Promise.resolve(callback()).then(() => { throw err; })
    )
}

promise中的race

用法：

Promise.race([readFile('./name.txt','utf8'),readFile('./age.txt','utf8')]).then(data=>{
    console.log(data);
});

实现：

Promise.race=function (arr) {
    return new Promise((resolve,reject)=>{
        for (let i = 0; i < arr.length; i++) {
            let currentValue=arr[i];
            //这个isPromise用的是上面promise.all文本块的方法
            if(isPromise(currentValue)){
                currentValue.then(data=>{
                    resolve(data)
                },reject)
            }else {
                resolve(currentValue)
            }
        }
    })
};