无法承诺基于回调的函数

Question

我想使用库 aztro-js，其文档中的典型调用如下所示：

const aztroJs = require("aztro-js");

//Get all horoscope i.e. today's, yesterday's and tomorrow's horoscope
aztroJs.getAllHoroscope(sign, function(res) {
   console.log(res);
});

出于多种原因，我想使用 async/await 风格并利用 try/catch 来使用它。所以我尝试像这样承诺：

const aztroJs = require("aztro-js");
const {promisify} = require('util');
const getAllHoroscopeAsync = promisify(aztroJs.getAllHoroscope);

async function handle() {
  let result, sign = 'libra';
  try {
    result = await getAllHoroscopeAsync(sign);
  }
  catch (err) {
    console.log(err);
  }
  console.log("Result: " + result);
}

但是，当我记录结果时，它是未定义的。我知道该调用有效，因为库会通过 console.log 自动记录响应，并且我在日志中看到了正确的响应。

我如何“等待”这个电话？ （即使通过其他方式，如果这不是“可承诺的”）

Answer 1

util.promisify()

期望回调函数接受两个参数，第一个是错误，没有错误时必须为

null

，有错误时必须为非 null，第二个是值（如果没有错误）。只有当回调遵循特定规则时，它才会正确地承诺函数。

要解决这个问题，您必须手动承诺您的功能。

// manually promisify
aztroJs.getAllHoroscopePromise = function(sign) {
    return new Promise(resolve => {
        aztroJs.getAllHoroscope(sign, function(data) {
            resolve(data);
        });
    });
};

// usage
aztroJs.getAllHoroscopePromise(sign).then(results => {
    console.log(results);
});

注意，返回数据的异步函数没有返回错误的方法是不寻常的，因此

aztroJs.getAllHoroscope()

接口在这方面似乎有点可疑。

事实上，如果您查看此函数的代码，您可以看到它正在使用

request()

库发出网络请求，然后在出现错误时尝试在异步回调中

throw

。这是一个完全有缺陷的设计，因为您（作为调用者）无法捕获异步抛出的异常。因此，这个包没有合理的方式来传达错误。设计得很差。

Answer 2

尝试自定义 Promisified 函数

aztroJs.getAllHoroscope[util.promisify.custom] = (sign) => {
  return new Promise((resolve, reject) => {
    aztroJs.getAllHoroscope(sign, resolve);
  });
};

const getAllHoroscopeAsync = util.promisify(aztroJs.getAllHoroscope);

Answer 3

您可以将 getAllHorscopeAsync 更改为 Promise 函数

示例：

const getAllHoroscopeAsync = (sign) => 
    new Promise(resolve => 
            aztroJs.getAllHoroscope(sign, (res) => resolve(res)));