我正在尝试定制battlenet-api库,它具有以下函数签名:
function (args, callback)callback的签名是:
function (err, body, res)在这种情况下,我需要在承诺执行之前添加一个速率限制器(节点速率限制器),因此函数如下:
function throttler(originalMethod) {
// return a function
return function throttled() {
var args = [].slice.call(arguments);
// Needed so that the original method can be called with the correct receiver
var self = this;
// which returns a promise
return new Promise(function(resolve, reject) {
// We call the originalMethod here because if it throws,
// it will reject the returned promise with the thrown error
rateLimiterByHour.removeTokens(1, function() {
rateLimiterBySecond.removeTokens(1, function() {
originalMethod.apply(self, args, function(err, body, res) {
if (err) { reject(err, body, res); }
else { resolve({err, body, res}); }
};
});
);
});
});
};
};
Promise.promisifyAll(require('battlenet-api').wow, {
promisifier: throttler
});throttler是
我一点也不确定这是否可行,或者我是否应该采取另一种办法。
我怎么才能适当地推广这一点呢?
发布于 2015-08-23 22:11:27
那应该是关于工作的。但是,reject只使用一个参数,如果err是错误的,您可能不希望将它作为实现值的一部分传递:
if (err) reject(err);
else resolve({body, res});发布于 2015-08-24 00:42:42
看上去应该管用的。但是,一个问题是,originalMethod回调必须是args数组的一部分,才能由Function#apply传入。类似于:
var callback = function(err, body, res) {
if (err) { reject(err); }
else { resolve({body, res}); }
}
...
originalMethod.apply(self, args.concat(callback));https://stackoverflow.com/questions/32171262
复制相似问题