Code
2023-05-07 08:00:05

如何将现有回调API转换为promise？

我想使用promise，但我有一个回调API，格式如下：

1.DOM加载或其他一次性事件：

window.onload; // set to callback
...
window.onload = function() {

};

2.普通回调：

function request(onChangeHandler) {
    ...
}
request(function() {
    // change happened
    ...
});

3.节点样式回调（“nodeback”）：

function getStuff(dat, callback) {
    ...
}
getStuff("dataParam", function(err, data) {
    ...
})

4.具有节点样式回调的整个库：

API;
API.one(function(err, data) {
    API.two(function(err, data2) {
        API.three(function(err, data3) {
            ...
        });
    });
});

我如何在promise中使用API，如何“promise”它？

当前回答

如果有几个函数需要回调，并且希望它们返回promise，则可以使用此函数进行转换。

function callbackToPromise(func){

    return function(){

        // change this to use what ever promise lib you are using
        // In this case i'm using angular $q that I exposed on a util module

        var defered = util.$q.defer();

        var cb = (val) => {
            defered.resolve(val);
        }

        var args = Array.prototype.slice.call(arguments);
        args.push(cb);    
        func.apply(this, args);

        return defered.promise;
    }
}
2016-08-04 00:45:36

其他回答

这已经晚了5年，但我想在这里发布我的promisify版本，它从回调API中获取函数，并将它们转化为承诺

const promesify = fn => {
  return (...params) => ({
    then: cbThen => ({
      catch: cbCatch => {
        fn(...params, cbThen, cbCatch);
      }
    })
  });
};

在这里查看这个非常简单的版本：https://gist.github.com/jdtorregrosas/aeee96dd07558a5d18db1ff02f31e21a

2019-04-04 21:55:37

您可以在ES6中使用本机Promise，例如处理setTimeout：

enqueue(data) {

    const queue = this;
    // returns the Promise
    return new Promise(function (resolve, reject) {
        setTimeout(()=> {
                queue.source.push(data);
                resolve(queue); //call native resolve when finish
            }
            , 10); // resolve() will be called in 10 ms
    });

}

在本例中，Promise没有失败的理由，因此永远不会调用reject（）。

2017-01-22 13:22:52

在Node.JS中将函数转换为promise之前

var request = require('request'); //http wrapped module

function requestWrapper(url, callback) {
    request.get(url, function (err, response) {
      if (err) {
        callback(err);
      }else{
        callback(null, response);             
      }      
    })
}


requestWrapper(url, function (err, response) {
    console.log(err, response)
})

转换后

var request = require('request');

function requestWrapper(url) {
  return new Promise(function (resolve, reject) { //returning promise
    request.get(url, function (err, response) {
      if (err) {
        reject(err); //promise reject
      }else{
        resolve(response); //promise resolve
      }
    })
  })
}


requestWrapper('http://localhost:8080/promise_request/1').then(function(response){
    console.log(response) //resolve callback(success)
}).catch(function(error){
    console.log(error) //reject callback(failure)
})

如果您需要处理多个请求

var allRequests = [];
allRequests.push(requestWrapper('http://localhost:8080/promise_request/1')) 
allRequests.push(requestWrapper('http://localhost:8080/promise_request/2'))
allRequests.push(requestWrapper('http://localhost:8080/promise_request/5'))    

Promise.all(allRequests).then(function (results) {
  console.log(results);//result will be array which contains each promise response
}).catch(function (err) {
  console.log(err)
});
2017-08-11 11:31:02

死灵一点，这个链接可能有用。。。。

太长，读不下去了看看这个答案末尾的代码片段示例

编写/转换可调用的函数

cb（错误，结果）或新Promise（…）格式

promiseToCB转换并导出先前编码为返回promise的现有函数cbToPromise转换并导出一个先前编码为调用最后一个参数的现有函数（error，result）如果包装函数提供了多个结果，则结果将是一个结果数组例如cb（undefined，path，stat）--->解析（[path，stat]）/cb（undefine，[path，stat]）asPromise允许您编写一个新函数以返回promise，但它可以以任何方式调用asCallback允许您编写一个新函数来调用cb（err，result），但它可以通过任何方式调用

示例函数

每个样本取2个参数，并基于随机数解决/拒绝/错误。

arg2也可以用于强制通过或失败。（查找“-通过”或“-失败”）。

包装现有函数

将函数导出到当前的“this”（或使用promiseToCB（函数myFunc（）｛｝，newThis）；）


    promiseToCB(function sampleFunc1(arg1,arg2) {
        console.log("deciding:",arg1,arg2);
        return new Promise(function(resolve,reject){
       
           const timer = setTimeout(function(){reject([arg1,arg2,"ouch"].join("-"));},5000);
           
           setTimeout(function(){
               if (arg2.endsWith("-pass") || (!arg2.endsWith("-fail") && Math.random()<0.5)) {
    
                   console.log("complete:",arg1,arg2);
                   clearTimeout(timer);
                   resolve([arg1,arg2,"all good"].join("-"));
               }
           },2000);
        
        });
    });
    
    cbToPromise('sampleFunc2',function someOtherName(arg1,arg2,cb) {
       console.log("deciding:",arg1,arg2);
       const timer = setTimeout(function(){cb([arg1,arg2,"ouch"].join("-"));},5000);
       
       setTimeout(function(){
           if (arg2.endsWith("-pass") || (!arg2.endsWith("-fail") && Math.random()<0.5)) {
               console.log("complete:",arg1,arg2);
               clearTimeout(timer);
               cb(undefined,[arg1,arg2,"all good"].join("-"));
           }
       },2000);
        
    },local);

或者编写嵌入包装器的新函数。

     function sampleFunc3(arg1,arg2) {return asPromise(arguments,function(resolve,reject){
       console.log("deciding:",arg1,arg2);
       const timer = setTimeout(function(){reject([arg1,arg2,"ouch"].join("-"));},5000);
       
       setTimeout(function(){
           if (arg2.endsWith("-pass") || (!arg2.endsWith("-fail") && Math.random()<0.5)) {
               console.log("complete:",arg1,arg2);
               clearTimeout(timer);
               resolve([arg1,arg2,"all good"].join("-"));
           }
       },2000);
        
    });}
    
    function sampleFunc4(arg1,arg2) {return asCallback(arguments,function(cb){
       console.log("deciding:",arg1,arg2);
       const timer = setTimeout(function(){cb([arg1,arg2,"ouch"].join("-"));},5000);
       
       setTimeout(function(){
           if (arg2.endsWith("-pass") || (!arg2.endsWith("-fail") && Math.random()<0.5)) {
               console.log("complete:",arg1,arg2);
               clearTimeout(timer);
               cb(undefined,[arg1,arg2,"all good"].join("-"));
           }
       },2000);
        
    });}

测试上述功能的scipt


    const local = {}; 
    promiseToCB(function sampleFunc1(arg1,arg2) {
        console.log("deciding:",arg1,arg2);
        return new Promise(function(resolve,reject){
       
           const timer = setTimeout(function(){reject([arg1,arg2,"ouch"].join("-"));},5000);
           
           setTimeout(function(){
               if (arg2.endsWith("-pass") || (!arg2.endsWith("-fail") && Math.random()<0.5)) {
    
                   console.log("complete:",arg1,arg2);
                   clearTimeout(timer);
                   resolve([arg1,arg2,"all good"].join("-"));
               }
           },2000);
        
        });
    });
    
    cbToPromise('sampleFunc2',function someOtherName(arg1,arg2,cb) {
       console.log("deciding:",arg1,arg2);
       const timer = setTimeout(function(){cb([arg1,arg2,"ouch"].join("-"));},5000);
       
       setTimeout(function(){
           if (arg2.endsWith("-pass") || (!arg2.endsWith("-fail") && Math.random()<0.5)) {
               console.log("complete:",arg1,arg2);
               clearTimeout(timer);
               cb(undefined,[arg1,arg2,"all good"].join("-"));
           }
       },2000);
        
    },local);
    
    function sampleFunc3(arg1,arg2) {return asPromise(arguments,function(resolve,reject){
       console.log("deciding:",arg1,arg2);
       const timer = setTimeout(function(){reject([arg1,arg2,"ouch"].join("-"));},5000);
       
       setTimeout(function(){
           if (arg2.endsWith("-pass") || (!arg2.endsWith("-fail") && Math.random()<0.5)) {
               console.log("complete:",arg1,arg2);
               clearTimeout(timer);
               resolve([arg1,arg2,"all good"].join("-"));
           }
       },2000);
        
    });}
    
    function sampleFunc4(arg1,arg2) {return asCallback(arguments,function(cb){
       console.log("deciding:",arg1,arg2);
       const timer = setTimeout(function(){cb([arg1,arg2,"ouch"].join("-"));},5000);
       
       setTimeout(function(){
           if (arg2.endsWith("-pass") || (!arg2.endsWith("-fail") && Math.random()<0.5)) {
               console.log("complete:",arg1,arg2);
               clearTimeout(timer);
               cb(undefined,[arg1,arg2,"all good"].join("-"));
           }
       },2000);
        
    });}
    
    const log=console.log.bind(console),info=console.info.bind(console),error=console.error.bind(console);
    
    sampleFunc1("sample1","promise").then (log).catch(error);
    local.sampleFunc2("sample2","promise").then (log).catch(error);
    sampleFunc3("sample3","promise").then (log).catch(error);
    sampleFunc4("sample4","promise").then (log).catch(error);

    sampleFunc1("sample1","callback",info);
    local.sampleFunc2("sample2","callback",info);
    sampleFunc3("sample3","callback",info);
    sampleFunc4("sample4","callback",info);
    
    sampleFunc1("sample1","promise-pass").then (log).catch(error);
    local.sampleFunc2("sample2","promise-pass").then (log).catch(error);
    sampleFunc3("sample3","promise-pass").then (log).catch(error);
    sampleFunc4("sample4","promise-pass").then (log).catch(error);

    sampleFunc1("sample1","callback-pass",info);
    local.sampleFunc2("sample2","callback-pass",info);
    sampleFunc3("sample3","callback-pass",info);
    sampleFunc4("sample4","callback-pass",info);
    
    
    sampleFunc1("sample1","promise-fail").then (log).catch(error);
    local.sampleFunc2("sample2","promise-fail").then (log).catch(error);
    sampleFunc3("sample3","promise-fail").then (log).catch(error);
    sampleFunc4("sample4","promise-fail").then (log).catch(error);
    
    sampleFunc1("sample1","callback-fail",info);
    local.sampleFunc2("sample2","callback-fail",info);
    sampleFunc3("sample3","callback-fail",info);
    sampleFunc4("sample4","callback-fail",info);

var cpArgs=Array.prototype.slice.call.bind（Array.proto原型.slice）；函数promiseToCB（nm，fn，THIS）{如果（nm类型==='功能'）{这=fn；fn=纳米；nm=fn.name；}此=此||此；const func=函数（）{let args=cpArgs（参数）；if（参数类型[args.length-1]=='函数'）{const cb=args.pop（）；return fn.apply（THIS，args）.then（函数（r）{cb（未定义，r）；}).捕获（cb）；}其他{return fn.apply（THIS，args）；}};Object.defineProperty（func，'name'，{value:nm，enumerable:false，可配置：true}）；如果（此[nm]）删除此[nm]；Object.defineProperty（THIS，nm，｛value:func，enumerable:false，可配置：true｝）；返回函数；}函数cbToPromise（nm，fn，THIS）{如果（nm类型==='功能'）{这=fn；fn=纳米；nm=fn.name；}此=此||此；const func=函数（）{let args=cpArgs（参数）；if（参数类型[args.length-1]=='函数'）{return fn.apply（THIS，args）；}其他{return new Promise（函数（解析，拒绝）{args.push（函数（错误，结果）{if（error）返回reject（err）；if（arguments.length==2）{返回解析（result）；}返回解析（cpArgs（arguments，1））；});fn.apply（此，参数）；});}};Object.defineProperty（func，'name'，{value:nm，enumerable:false，可配置：true}）；如果（此[nm]）删除此[nm]；Object.defineProperty（THIS，nm，｛value:func，enumerable:false，可配置：true｝）；返回函数；}函数作为Promise（args，解析器，no_err）{常量cb=参数[args.length-1]，promise=新promise（解析器）；return（cb类型=='函数'）？promise.then（函数（结果）｛return cb（no-err，结果）｝）.catch（cb）：promise；}函数作为回调（args，wrap，no_err）{常量cb=参数[args.length-1]，promise=新promise（函数解析器（resolve，reject）{返回换行（函数（错误，结果）{if（error）返回reject（err）；解决（结果）；});});return（cb类型=='函数'）？promise.then（函数（结果）｛return cb（no-err，结果）｝）.catch（cb）：promise；}函数cbPromiseTest（）{/*全局样本Func1，样本Func2*/常量local={}；promiseToCB（函数sampleFunc1（arg1，arg2）{console.log（“决定：”，arg1，arg2）；return new Promise（函数（解析，拒绝）{const timer=setTimeout（函数（）｛reject（[arg1，arg2，“ouch”].jjoin（“-”）；｝，5000）；setTimeout（函数）{if（arg2.endsWith（“-pass”）||（！arg2.ends With（”-ffail“）&&Math.random（）<0.5））{console.log（“完成：”，arg1，arg2）；clearTimeout（计时器）；解析（[arg1，arg2，“一切正常”].join（“-”））；}},2000);});});cbToPromise（'sampleFunc2'，函数someOtherName（arg1，arg2，cb）{console.log（“决定：”，arg1，arg2）；const timer=setTimeout（函数）｛cb（[arg1，arg2，“ouch”].jjoin（“-”）；｝，5000）；setTimeout（函数）{if（arg2.endsWith（“-pass”）||（！arg2.ends With（”-ffail“）&&Math.random（）<0.5））{console.log（“完成：”，arg1，arg2）；clearTimeout（计时器）；cb（未定义，[arg1，arg2，“all good”]。join（“-”））；}},2000);}，本地）；函数sampleFunc3（arg1，arg2）｛return asPromise（参数，函数（解析，拒绝）{console.log（“决定：”，arg1，arg2）；const timer=setTimeout（函数（）｛reject（[arg1，arg2，“ouch”].jjoin（“-”）；｝，5000）；setTimeout（函数）{if（arg2.endsWith（“-pass”）||（！arg2.ends With（”-ffail“）&&Math.random（）<0.5））{console.log（“完成：”，arg1，arg2）；clearTimeout（计时器）；解析（[arg1，arg2，“一切正常”].join（“-”））；}},2000);});}函数sampleFunc4（arg1，arg2）｛return asCallback（参数，函数（cb）{console.log（“决定：”，arg1，arg2）；const timer=setTimeout（函数）｛cb（[arg1，arg2，“ouch”].jjoin（“-”）；｝，5000）；setTimeout（函数）{if（arg2.endsWith（“-pass”）||（！arg2.ends With（”-ffail“）&&Math.random（）<0.5））{console.log（“完成：”，arg1，arg2）；clearTimeout（计时器）；cb（未定义，[arg1，arg2，“all good”]。join（“-”））；}},2000);});}const log=console.log.bind（控制台），info=console.info.bind（控制台，error=console.error.bind）；sampleFunc1（“sample1”，“promise”）.then（log）.catch（error）；local.sampleFunc2（“sample2”，“promise”）.then（log）.catch（error）；sampleFunc3（“sample3”，“promise”）.then（log）.catch（error）；sampleFunc4（“sample4”，“promise”）.then（log）.catch（error）；sampleFunc1（“sample1”，“回调”，信息）；local.sampleFunc2（“sample2”，“回调”，信息）；sampleFunc3（“sample3”，“回调”，信息）；sampleFunc4（“sample4”，“回调”，信息）；sampleFunc1（“sample1”，“promise pass”）.then（log）.catch（error）；local.sampleFunc2（“sample2”，“pr”

2021-06-15 03:42:43

es6 promisify将基于回调的函数转换为基于Promise的函数。

const promisify = require('es6-promisify');

const promisedFn = promisify(callbackedFn, args);

裁判：https://www.npmjs.com/package/es6-promisify

2017-10-17 23:56:27

推荐文章

aliyun

最新文章

标签

2025 code 京ICP备15047053号-1