koa2上传文件stream没有处理完直接return结果？

Question

const router = require('koa-router')();
const fs = require('fs');

router.post('/upload', async (ctx){
    const file = ctx.request.body.files.file;    // 获取上传文件
    const reader = fs.createReadStream(file.path);    // 创建可读流
    const ext = file.name.split('.').pop();        // 获取上传文件扩展名
    const upStream = fs.createWriteStream(`upload/${Math.random().toString()}.${ext}`);        // 创建可写流
    reader.pipe(upStream);    // 可读流通过管道写入可写流 
    return ctx.body = '上传成功';
})

上面代码是上传文件，其中这段不理解：

reader.pipe(upStream);    // 可读流通过管道写入可写流 
return ctx.body = '上传成功'; //这里直接返回结果

我的疑惑是：stream执行完需要一定时间，而且它又是异步的，可以说这里是直接return '上传成功'，我们都知道，return就相当于结束了这次的http请求，那么没有执行完的stream怎么办？

Answer 1

利用EventEmitter提供的事件
然后你可以把上面的代码 我这里简单写一下 类似这样封装一下

function getFile (reader, upStream) {
 return new Promise(function (resolve, reject) {
  let stream = reader.pipe(upStream); 
  stream.on('finish', function () {
   console.log('文件上传成功！');
  });
 });
}