如何通过 Promise 使这段代码异步？

Question

任何胶水。 请不要给出 SETTIMEOUT 的例子。

我的主管说，如果 then() 没有返回任何新的承诺，则没有必要有更多 then() 语句。我无法完全理解，我看过 Exploring ES6 但没有很好的例子我的情况。

let readData = new Promise(function (resolve, reject) {
    fs.readFile('/home/geek/Desktop/activity-logs.csv', 'utf8', (err, data) => {
        if (err)
            reject();
        resolve(data);

    });

});

readData
    .then((data) => {
        bankLogs = splitString(data, ';')
    })
    .then(() => {
        for (let index = 2; index < bankLogs.length; index += 5) {
            objectOfUsers[bankLogs[index]] = {}
            temporarySymbols.push(bankLogs[index].concat(bankLogs[index + 1]));
        }
        Object.keys(objectOfUsers).forEach(function (element) {
            objectKeys.push(element)
        });
        for (let index = 0; index < objectKeys.length; index++)
            createObject(index);
        console.log(objectOfUsers)
    })
    .catch((err) => console.log('Error happened : ' + err));

Answer 1

从您的代码 sn-p 中，您实现了 Promise 链，其中解决一个 Promise 会初始化并返回一个新的。

类似：

let readData = new Promise(/* ... */);

readData.then((data) => {
        let promise2 = new Promise(/* ... */);
        return promise2;
    }).then(() => {
        // ...
    })
    .catch((err) => console.log('Error happened : ' + err));

但是在解决readData之后，你只写了简单的逻辑，并没有新的承诺：bankLogs = splitString(data, ';')

应该是这样的：

let readData = new Promise(function (resolve, reject) {
    fs.readFile('/home/geek/Desktop/activity-logs.csv', 'utf8', (err, data) => {
        if (err)
            reject();
        resolve(data);    
    });    
});

readData.then((data) => {
    var bankLogs = splitString(data, ';')

    for (let index = 2; index < bankLogs.length; index += 5) {
        objectOfUsers[bankLogs[index]] = {}
        temporarySymbols.push(bankLogs[index].concat(bankLogs[index + 1]));
    }
    Object.keys(objectOfUsers).forEach(function (element) {
        objectKeys.push(element)
    });
    for (let index = 0; index < objectKeys.length; index++)
        createObject(index);
    console.log(objectOfUsers)
})
.catch((err) => console.log('Error happened : ' + err));

---

如果您仅在 Promise 中使用 bankLogs，请将其设为私有。

---

Promise 链 方法我们主要用于良好的代码可读性和为所有 Promise 处理一个错误回调。

编辑

您可以使用一些包装对象或项目列表（示例）通过 Promise 链传递值：

'use strict';

var fs = require('fs');

let readData = new Promise(function (resolve, reject) {
    fs.readFile('/Users/maxim/Appsflyer/projects/ZEVEL/file1.txt', 'utf8', (err, data) => {
        if (err)
            reject();

        var obj = {
            data: data,
            bankLogs: {} // in 1st Promise initialize bankLogs
        };    
        resolve(obj);    
    });    
});

// 2nd dummy Promise 
let newReadData = new Promise(function (resolve, reject) {
    fs.readFile('/Users/maxim/Appsflyer/projects/ZEVEL/file2.txt', 'utf8', (err, data) => {
        if (err)
            reject();
        resolve(data);

    });

});

readData.then((obj1) => {   

    obj1.bankLogs.value = "someValue";

    return newReadData.then(function(data2){       
        obj1.data2 = data2;
        return obj1;
    });
}).then((dataTotal) => {   
    console.log(dataTotal);

})
.catch((err) => console.log('Error happened : ' + err));