代码之家 › 专栏 › 技术社区 › Fede E.

具有嵌套函数的节点异步函数

node.js javascript

Fede E. · 技术社区 · 7 年前

processFile: async function(req, whatTo, callback){

    const lines = [];

    const lineReader = require('readline').createInterface({
        input: require('streamifier').createReadStream(req.file.buffer)
    });

    let errorPresent = false;

    lineReader.on('line', line => {
        lines.push(line.replace(/ /g,''));
    });

    lineReader.on('close', async () => {

        try {

            const results = await Promise.map(lines, async(line) => {

                return await Transform(line);

            }, { concurrency: 80 });

            return results.join("\r\n");

        }catch(err){
            throw err;
        }

    });

}

然后我有一个路由,它调用这个函数,如下所示:

const data = await tokenizer.processFile(req, 'tokenize');

res.setHeader('Content-Type', 'text/plain'); 
res.setHeader('Content-Disposition', 'attachment; filename=tokenized.txt');
res.write(data, 'binary');
res.end();

return results.join("\r\n");

我怎样才能做到这一点?

1 回复 | 直到 7 年前

Cody Geisler 7 年前

processFile: (req, whatTo) => new Promise((res,rej)=>{

    const lines = [];

    const lineReader = require('readline').createInterface({
        input: require('streamifier').createReadStream(req.file.buffer)
    });

    let errorPresent = false;

    lineReader.on('line', line => {
        lines.push(line.replace(/ /g,''));
    });

    lineReader.on('close', function(){
      res(lines);
    });
    // UNCAUGHT ERRORS, USE rej() for others
});

然后在异步/等待世界中处理您的转换,如下所示:

let data;
let lines = await tokenizer.processFile(req, 'tokenize');
let results = await Promise.map(lines, async (line) => {
  return await Transform(line);
}, { concurrency: 80 });

推荐文章

code-geek · Jquery根据单选按钮选择隐藏或显示文本字段

3 月前

Niobos · 如何/是否有方法使通用算法函数同时与同步和异步函数一起工作?

3 月前

Alex · 在轻量级中同时解构和不解构变量

3 月前

Ângelo Rigo · ReactJS映射:如何迭代[关闭]

3 月前

bairog · 从按属性筛选的对象数组字典中创建值数组

3 月前

KaiMcKiernan · 基于Math.random()的函数在另一个函数内不起作用[关闭]

3 月前

David Jeong · 浏览器不会为浏览器自动添加的某些标头发送CORS预检请求吗?

3 月前

user29519291 · 为不同的变量创建一个带有可重用Click函数的简单菜单

4 月前

user3472810 · Angular@Output/EventEmitter返回undefined

4 月前

lokiuucx · JS对象属性返回未定义,尽管对象属性应该有值

4 月前