代码之家 › 专栏 › 技术社区 › Thamaraiselvam

如何在异步函数中调用父类函数

asynchronous node.js javascript

Thamaraiselvam · 技术社区 · 7 年前

pushBulkData 流读取事件中的函数。

我试过了

this.pushBulkData(row, importData);

我知道这行不通,因为这里有单独的范围

和

taskController.pushBulkData(row, importData);

这不可能一直都这样。

会吗 bind 工作?

class taskController{
    async import(path){

        var dest = fs.createWriteStream(path);

        src.pipe(dest);

        let importData = [];

        src.on('end', function() {
            fs.createReadStream(path)
            .pipe(require('csv-parser')(['name', 'status']))
            .on('data', function (row) {
                //this makes error
                this.pushBulkData(row, importData);
            })
            .on('end', function () {

                // We are done
            })
        });
        src.on('error', function(err) { console.log('error on upload file'); });
    }

    pushBulkData(row, importData){
        console.log('row', row);         

        importData.push(
            {
                name          : row.name,
                status        : row.status}
        );
    }
}
}

2 回复 | 直到 7 年前

james emanon 7 年前

尝试更改为箭头函数,因为它们没有自己的“this”上下文。因此,父类“this”就是它所指的:

    src.on('end', () => {
        fs.createReadStream(path)
        .pipe(require('csv-parser')(['name', 'status']))
        .on('data', row => {
            //this makes error
            this.pushBulkData(row, importData);
        })
        .on('end', function () {

            // We are done
        })
    });

Ridham Tarpara 7 年前

src.on('end', () => {
    fs.createReadStream(path)
    .pipe(require('csv-parser')(['name', 'status']))
    .on('data', row => {
        //this won't make error
        this.pushBulkData(row, importData);
    })
    .on('end', function () {

        // We are done
    })
});

或者如果你不想使用箭头功能,那么你可以保存 this 另一个变量并使用它。

async import(path){

    var dest = fs.createWriteStream(path);

    src.pipe(dest);

    let importData = [];
    const _this = this;
    src.on('end', function() {
        fs.createReadStream(path)
        .pipe(require('csv-parser')(['name', 'status']))
        .on('data', function (row) {
            //this won't make error
            _this.pushBulkData(row, importData);
        })
        .on('end', function () {

            // We are done
        })
    });
    src.on('error', function(err) { console.log('error on upload file'); });
}

推荐文章

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

1 年前

Rami Dhouib · Flutter:如果等待时间超过2秒,则执行操作

1 年前

Jess The Witch · GCP云功能中处理延迟任务的模式

1 年前

justiceorjustus · Javascript中异步递归函数块内部是否有同步函数调用?

1 年前

Plup · 连接失败时,PyMongo异步客户端未引发异常

1 年前

user1233894 · 尝试从全局函数传递值

1 年前

ZNackasha · 如何将Arc<RwLock<dyn Child>>转换为Arc<RwLock<dyn-Base>>

2 年前

Grigory Turlykin · 发送媒体python电报机器人(ASYNC)

2 年前

Fabiano Taioli · 管理单线程Rust中的阻塞函数

2 年前

river7816 · 为什么spdlog不在async函数中打印

2 年前