node.js - 确保 promise 在 transformFunction 中得到解决

Question

我正在学习through2和sequelize。

我的代码：

  return Doc.createReadStream({
    where: { /*...*/ },
    include: [
      {
        /*...*/
      },
    ],
  })
  .pipe(through({ objectMode: true }, (doc, enc, cb) => {
    Comment.findOne(null, { where: { onId: doc.id } }).then((com) => { /* sequelize: findOne*/
      com.destroy(); /* sequelize instance destroy: http://docs.sequelizejs.com/manual/tutorial/instances.html#destroying-deleting-persistent-instances */
      cb();
    });
  }))
  .on('finish', () => {
    console.log('FINISHED');
  })
  .on('error', err => console.log('ERR', err));

我试图清楚地表达我的问题。Doc并且Comment是续集模型。我想使用流从数据库中一一读取文档实例并删除每个文档实例上的注释。Comment.findOne并且com.destroy()都会返回承诺。我想为每个解决的承诺doc然后调用cb(). 但是我上面的代码不能工作，在com 被销毁之前，代码已经运行完毕。

如何解决？谢谢

我将上面的代码包装在mocha测试中，比如

it('should be found by readstream', function _testStream(){
  /* wrap the first piece of codes here*/
});

但在流完成读取之前，测试存在。

Answer 1

你可以通过返回 promise 并使用 another 来等待另一个 promise .then。

在运行之前，您可能还需要检查com结果。null.destroy()

  .pipe(through({ objectMode: true }, (doc, enc, cb) => {
    Comment.findOne(null, { where: { onId: doc.id } })
      .then(com => com.destroy())
      .then(()=> cb())
      .catch(cb)
  }))

done然后在 mocha 中运行测试时，您需要通过添加到测试函数签名并done()在完成或错误时调用来等待异步流。

it('should be found by readstream', function _testStream(done){
  ...
  .on('finish', () => done())
  .on('error', done)
})