node.js - ノードストリームは終了していませんが、終了を発行します

Question

私はこれを読んで、例に基づいてコードを書きました。

私のコード:

const through = require('through2'); const bluebird = require('bluebird');

function streamToPromise(stream) {
  return new Promise(function(resolve, reject) {
    stream.resume();
    stream.on("end", resolve);
    stream.on("error", reject);
  });
};

module.exports = {
  up: function up() {
    console.log('startstream');
    // Doc is sequelize Model
    const stream = Doc.createReadStream({
      include: [
        {
          repository: AssociatedRepo,
          as: 'on',
          required: false,
        },
      ],
    });

    stream.pipe(through({ objectMode: true }, (doc, enc, cb) => {
      console.log('docid', doc.id);
      return doc.destroy()
        .then(() => cb());
    }));
    return streamToPromise(stream).then((data) => {
      console.log('xxxxxxxxxx', data);
      return null;
    });
  },
};

上記のプログラムを使用して、約 400 レコードの読み取りと削除を試みました。しかし、ログから、ストリーム promise ( streamToPromise(stream)) は解決されていますが、まだいくつかのレコードが残っていることがわかりました。ログから、私は得ました：

xxxxxxxxxx undefined
docid 89934915596

これを修正する方法は？ありがとう