我想使用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”它？
在Node.js 8.0.0的候选版本中，有一个新的实用程序util.profisify（我已经写过util.proficify），它封装了promising任何函数的能力。
它与其他答案中建议的方法没有太大不同，但具有作为核心方法而不需要额外依赖性的优点。
const fs = require('fs');
const util = require('util');
const readFile = util.promisify(fs.readFile);
然后有一个readFile方法，它返回一个本机Promise。
readFile('./notes.txt')
.then(txt => console.log(txt))
.catch(...);
在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)
});
您可以在NodeJS中使用JavaScript本机承诺。
My Cloud 9代码链接：https://ide.c9.io/adx2803/native-promises-in-node
/**
* Created by dixit-lab on 20/6/16.
*/
var express = require('express');
var request = require('request'); //Simplified HTTP request client.
var app = express();
function promisify(url) {
return new Promise(function (resolve, reject) {
request.get(url, function (error, response, body) {
if (!error && response.statusCode == 200) {
resolve(body);
}
else {
reject(error);
}
})
});
}
//get all the albums of a user who have posted post 100
app.get('/listAlbums', function (req, res) {
//get the post with post id 100
promisify('http://jsonplaceholder.typicode.com/posts/100').then(function (result) {
var obj = JSON.parse(result);
return promisify('http://jsonplaceholder.typicode.com/users/' + obj.userId + '/albums')
})
.catch(function (e) {
console.log(e);
})
.then(function (result) {
res.end(result);
})
})
var server = app.listen(8081, function () {
var host = server.address().address
var port = server.address().port
console.log("Example app listening at http://%s:%s", host, port)
})
//run webservice on browser : http://localhost:8081/listAlbums
我通常使用的一个简单的泛型函数。
const promisify = (fn, ...args) => {
return new Promise((resolve, reject) => {
fn(...args, (err, data) => {
if (err) {
return reject(err);
}
resolve(data);
});
});
};
如何使用它
函数promify接受带有回调的函数：
const cb = (result) => `The result is ${result}`;
const sum = (a, b, cb) => {
const result = a + b;
cb(result); // passing args to the callback function
}
// using the util
promise = promisify(sum, 3, 1, cb);
promise.then(x => console.log(x)) // 4
您可能不需要这个答案，但这将有助于了解可用实用程序的内部工作原理
在Node.js 8.0.0的候选版本中，有一个新的实用程序util.profisify（我已经写过util.proficify），它封装了promising任何函数的能力。
它与其他答案中建议的方法没有太大不同，但具有作为核心方法而不需要额外依赖性的优点。
const fs = require('fs');
const util = require('util');
const readFile = util.promisify(fs.readFile);
然后有一个readFile方法，它返回一个本机Promise。
readFile('./notes.txt')
.then(txt => console.log(txt))
.catch(...);
