javascript - 如何使用 Q 将事件监听器转换为 Promise

Question

大家好，我是 nodejs 的新手，我正在尝试学习 promises。我正在尝试实现一种菜单，该菜单将根据用户输入执行某些功能。这是我正在使用的代码:

var q = require('q');
var readline = require('readline-sync');

function createNewPreset(){
    var deferred = q.defer();
    var preset = {
        "name" : undefined,
        "unit" : undefined,
        "interval" : undefined,
        "files" : [],
    }
    deferred.resolve(preset);
    return deferred.promise;
}
function addPreset(){
    console.log("adding");
    var deferred = q.defer();
    createNewPreset()
    .then(function(){
        console.log("Gettind input in addPreset");
    })
    .then(getUserInput)
    .then(function(data){
        console.log("Adding data" + data);
    });
}
function getUserInput(){
    var deferred = q.defer();
    var stdin = process.stdin;
    stdin.resume();
    stdin.once('data', function(data){
        data = data.toString().trim()
        if(data.length > 20){
                var err = new Error("The entered preset name is too long");
                deferred.reject(err);
        }
        else{
                deferred.resolve(data);
        }
    });
    return deferred.promise;
}

function processChoice(input){
    var deferred = q.defer();
    var error = undefined;
    var func;
    switch(input){
        case "a":
                func = addPreset;               
        break;
        case "q":
                func = function(){
                        process.exit();
                }
        break;
        default:
                error = new Error("Invalid menu option entered.");
            deferred.reject(error);
        break;
    }
    deferred.resolve(func);
    return deferred.promise;
}
function prompt(){
    var stdout = process.stdout;
       //indicates that prompt is being executed
    stdout.write("(tic): ");
    console.log("Waiting for input");
    getUserInput()
    .then(processChoice)
    .then(function(func){ func(); })
    .catch(function(err) {console.log(err)})
    .then(prompt);
}
prompt();

我认为问题出在 getUserInput() 和 addPreset() 以及事件监听器中。我希望 promise 链仅在激活事件监听器后才继续，但老实说我不确定该怎么做。

这是我的结果:

(tic): Waiting for input
a
adding
Gettind input in addPreset
(tic): Waiting for input
A
Adding dataA
[Error: Invalid menu option entered.]
(tic): Waiting for input

我想让链在继续之前等待事件监听器执行。有什么办法可以做到这一点？

Answer 1

您的代码中有一些错误

排名不分先后

• .then(function(func){ func(); }) 应该是 .then(function(func){ return func(); }) - 因为func 返回一个你想要等待的 promise ，没有 return 在 addPreset resolved
之前进程继续
• 在几个函数中你创建了一个 deferred 但没有使用它 - 删除了那些
• 其他地方你创建一个你解析并返回的延迟，只返回一个q.resolve()

下面的代码根本没有使用 q promises，我已经改为原生 Promise 来测试我的答案 - 但转换回应该很简单q

function createNewPreset(){
    return Promise.resolve({
        "name" : undefined,
        "unit" : undefined,
        "interval" : undefined,
        "files" : [],
    });
}
function addPreset(){
    console.log("adding");
    return createNewPreset()
    .then(function(){
        console.log("Gettind input in addPreset");
    })
    .then(getUserInput)
    .then(function(data){
        console.log("Adding data " + data);
    });
}
function getUserInput(){
    return new Promise(function(resolve, reject) {
        var stdin = process.stdin;
        stdin.resume();
        stdin.once('data', function(data){
            data = data.toString().trim()
            if(data.length > 20){
                var err = new Error("The entered preset name is too long");
                reject(err);
            }
            else{
                resolve(data);
            }
        });
    });
}

function processChoice(input){
    return new Promise(function(resolve, reject) {
        var error = undefined;
        var func;
        switch(input){
            case "a":
                func = addPreset;               
            break;
            case "q":
                func = function(){
                    process.exit();
                }
            break;
            default:
                error = new Error("Invalid menu option entered.");
                reject(error);
            break;
        }
        resolve(func);
    });
}
function prompt(){
    var stdout = process.stdout;
       //indicates that prompt is being executed
    stdout.write("(tic): ");
    console.log("PROMPT waiting for input");
    getUserInput()
    .then(processChoice)
    .then(function(func){ return func(); })
    .catch(function(err) {console.log(err)})
    .then(prompt);
}
prompt();