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怎么办?
1 回答
交互式爱情
TA贡献1712条经验 获得超3个赞
利用EventEmitter提供的事件
然后你可以把上面的代码 我这里简单写一下 类似这样封装一下
function getFile (reader, upStream) { return new Promise(function (resolve, reject) { let stream = reader.pipe(upStream); stream.on('finish', function () { console.log('文件上传成功!'); }); }); }
- 1 回答
- 0 关注
- 886 浏览
添加回答
举报
0/150
提交
取消