'done event is being called even when pausing the connection'



>我正在尝试从csv读取,并且我正在暂停流,因为我需要使用await执行一些异步任务。但是,在处理完所有行之前调用 done 事件。据我了解,即使暂停也不能阻止调用完成的 fron。这有什么工作吗?

let res = csv({
delimiter: '|',
// noheader: true,
output: "csv",
nullObject: true
})
.fromStream(fs.createReadStream(`./dbscvs/new_${table.name}.csv`))
.on('data', async (data) => {
res.pause()
await new Promise(resolve=>{
setTimeout(resolve,5000)
})
res.resume()
})
.on('done', async e => {
console.log('done')
})
.on('error', (err) => {
console.log(err)
})

尝试end事件,该事件在输出完所有数据后发出。

最新更新