如何从node-oracledb toQueryStream()中检索值作为Promise

const oracledb = require('oracledb');
const Promise = require('bluebird');

function retrieveValues() {
  return new Promise((resolve, reject) => {
    oracledb.getConnection((err, connection) => {
      if (err) {
        reject(err);
        return;
      }

      const query = "SELECT * FROM your_table";
      const stream = connection.queryStream(query);

      const rows = [];
      stream.on('data', (row) => {
        rows.push(row);
      });

      stream.on('end', () => {
        resolve(rows);
        connection.close();
      });

      stream.on('error', (err) => {
        reject(err);
        connection.close();
      });
    });
  });
}

retrieveValues()
  .then((rows) => {
    console.log(rows); // 处理检索到的值
  })
  .catch((err) => {
    console.error(err); // 处理错误
  });