在解析下一个之前解析 $q.all 中每个 promise 中的整个链

Question

我正在循环遍历一个数组，并且在每个循环中，我添加一个 promise 数组，然后将其传递给 $q.all。每个链包括一个confirm() 对话和一个modal。用户的事件顺序应该是确认（） - 模式 - 确认（） - 模式。相反，我得到了确认（） - 确认（） - 模态 - 模态。另外，我希望在最后一个模式关闭后执行一个函数 refreshSelection()，但它目前会在最后一个 confirm() 对话关闭后立即触发。

    var promiseArr = [];
    var selection = []; // [obj1, obj1, obj3...]

    for (var i = 0; i < selection.length; i++) {
        promiseArr.push(getData(i));
    }

    $q.all(promiseArr)
        .then(refreshSelection);

    function getData(i) {
        var opts = {}; // selection[i].id is param

        return $http(opts)
            .then(onGetSuccess(i));
    }

    function onGetSuccess(i) {
        return function(result) {
            var shouldOpenModal = confirm(selection[i].text);

            if (shouldOpenModal == true) {
                openModal();
            }
        }
    }

    function openModal() {
        var copyPunchesModal = $uibModal.open({
            // modal template options
            }
        });

        copyPunchesModal.result.then(otherFunc, function () {
            console.log("Modal closed");
        });
    }

    function refreshSelection() {
        selection = [];
    }

我也尝试了以下方法，但无济于事。

    //...
    function getData(i) {
        var opts = {}; // selection[i].id is param

        return $http(opts)
            .then(onGetSuccess(i))
            .then(openConfirm)
            .then(openModal);
    }

非常感谢您的帮助。

Answer 1

你想使用一个 $.when 函数，它接受多个 promise 作为参数，并在它们全部完成时执行一个函数。或者，如果您同意它们按顺序完成，您可以将它们全部连接在一起。

https://api.jquery.com/jquery.when/

Answer 2

Q.all 没有指定解决承诺的顺序。如果您希望按照数组的顺序完成 Promise，则需要链接 Promise，以便当前 Promise 在前一个 Promise 的 .then() 内执行。

你可以用 reduce 干净地做到这一点。

I've got an answer here for ES6 promises，这里适配为Q：

deferred = $q.defer();
deferred.resolve();
return selection.reduce(
    (accumulator, current) => accumulator.then(()=>getData(current)), 
    deferred.promise
);

请注意，您还需要修改 getData 函数以对对象本身进行操作（例如，currentSelection.text 而不是 selection[i].text）

Answer 3

我想做类似的事情来避免溢出我的程序正在控制的设备 - 基本上我需要等待异步事务完成，然后再开始下一个事务。我使用 Promise 来强制执行执行顺序，并阻止直到每个项目完成。

// the async thing we want to do, wrapped in a promise
//
function sendMessage = (message) {
    var promise = new Promise (resolve, reject) {
        // send message via an async function that provides success & fail callbacks, e.g. AJAX
        // replace 'asyncFunction', it's just a placeholder in this example
        asyncFunction (message, 
            function (response) {   // success callback
                if (/*response is to my liking*/) {
                    resolve ();
                } else {
                    reject (new Error (/*why I didn't like the response*/));
                }
            },
            function (error) {  // failure callback
                reject (error);
            }
    };
    return promise;
}

// the array we want to process in order
var myMessages = ['hello', 'world', 'how', 'are', 'you', 'today?'];

// iterator, and recursive function to loop thru array
var idx = 0;
function next () {
    if (idx < myMessages.length) {
        sendMessage (myMessages[idx++]).then (
            next,   // maps to the 'resolve' call in sendMessage
            function (err) {    // maps to the 'reject' calls in sendMessage
                throw err;  // clearly, there's an option to be smarter than this
            }
        )
    }
}

// start the recursion
next ();