我有一个简化的函数，如下所示：
function(query) {
myApi.exec('SomeCommand', function(response) {
return response;
});
}
基本上我希望它调用myApi.exec，并返回回调 lambda 中给出的响应。但是，上面的代码不起作用，只是立即返回。
只是为了一个非常hackish的尝试，我尝试了以下不起作用，但至少你明白我想要实现的目标：
function(query) {
var r;
myApi.exec('SomeCommand', function(response) {
r = response;
});
while (!r) {}
return r;
}
基本上，什么是好的“node.js/事件驱动”方式来解决这个问题？我希望我的函数等到回调被调用，然后返回传递给它的值。
这样做的“好的 node.js /事件驱动”方式是不等待。
与使用 node 等事件驱动系统时的几乎所有其他事情一样，您的函数应该接受一个回调参数，该参数将在计算完成时被调用。调用者不应等待正常意义上的值“返回”，而是发送将处理结果值的例程：
function(query, callback) {
myApi.exec('SomeCommand', function(response) {
// other stuff here...
// bla bla..
callback(response); // this will "return" your value to the original caller
});
}
所以你不要这样使用它：
var returnValue = myFunction(query);
但像这样：
myFunction(query, function(returnValue) {
// use the return value here instead of like a regular (non-evented) return value
});
实现此目的的一种方法是将 API 调用包装到一个 Promise 中，然后使用它await来等待结果。
// let's say this is the API function with two callbacks,
// one for success and the other for error
function apiFunction(query, successCallback, errorCallback) {
if (query == "bad query") {
errorCallback("problem with the query");
}
successCallback("Your query was <" + query + ">");
}
// myFunction wraps the above API call into a Promise
// and handles the callbacks with resolve and reject
function apiFunctionWrapper(query) {
return new Promise((resolve, reject) => {
apiFunction(query,(successResponse) => {
resolve(successResponse);
}, (errorResponse) => {
reject(errorResponse);
});
});
}
// now you can use await to get the result from the wrapped api function
// and you can use standard try-catch to handle the errors
async function businessLogic() {
try {
const result = await apiFunctionWrapper("query all users");
console.log(result);
// the next line will fail
const result2 = await apiFunctionWrapper("bad query");
} catch(error) {
console.error("ERROR:" + error);
}
}
// call the main function
businessLogic();
输出：
Your query was <query all users>
ERROR:problem with the query
检查这个：https : //github.com/luciotato/waitfor-ES6
您使用 wait.for 的代码：（需要生成器，--harmony 标志）
function* (query) {
var r = yield wait.for( myApi.exec, 'SomeCommand');
return r;
}
如果您不想使用回调，则可以使用“Q”module。
例如：
function getdb() {
var deferred = Q.defer();
MongoClient.connect(databaseUrl, function(err, db) {
if (err) {
console.log("Problem connecting database");
deferred.reject(new Error(err));
} else {
var collection = db.collection("url");
deferred.resolve(collection);
}
});
return deferred.promise;
}
getdb().then(function(collection) {
// This function will be called afte getdb() will be executed.
}).fail(function(err){
// If Error accrued.
});
有关更多信息，请参阅：https : //github.com/kriskowal/q
如果你想让它非常简单和容易，没有花哨的库，在执行其他一些代码之前，等待回调函数在节点中执行，是这样的：
//initialize a global var to control the callback state
var callbackCount = 0;
//call the function that has a callback
someObj.executeCallback(function () {
callbackCount++;
runOtherCode();
});
someObj2.executeCallback(function () {
callbackCount++;
runOtherCode();
});
//call function that has to wait
continueExec();
function continueExec() {
//here is the trick, wait until var callbackCount is set number of callback functions
if (callbackCount < 2) {
setTimeout(continueExec, 1000);
return;
}
//Finally, do what you need
doSomeThing();
}