1

我在我的应用程序中使用bluebird作为控制流,我正在尝试实现promisify以将我的递归函数扩展为一个promise,但似乎“then”方法从未被执行

我正在做从一个 JSON 对象到另一个对象的映射,find 函数递归地查看 JSON 属性并根据特定条件返回属性。

var promise = require("bluebird");
var mapToModel = function(res){
  // res is a json structure
  var processes = res.definitions.process;
  var diagrams = res.definitions.BPMNDiagram; 
  var documents = [];
  for(var prop in processes) {
    if(processes.hasOwnProperty(prop)){
      var propertyNames = Object.getOwnPropertyNames(processes[prop]);
      for(var property in processes[prop]){
        var mapping ={};
        if(property==="$"){
          //do something with the process
        }else{
        //shapes
          mapping.hash = hash.hashCode(new Date().toString());
          mapping.type = property;
          mapping.value = processes[prop][property];
            var bpmnItem = findPromise(processes[prop][property], function(x) {return x.$.id;}).then(function(value){
              //I'm not reaching this point
              var bpmnId = value.$.id;
              console.log(value);
              if(bpmnId!=undefined){
                console.log("return:"+ bpmnId);
              }  
          });

          documents.push(mapping);
        }
      }
    }
     return documents;
  }
}

var findPromise = promise.promisify(find);
function find(items,f) {
    for(var key in items) { 
        var elem = items[key]; 
        if (f(elem)) { return elem;}
        if(typeof elem === "object") { 
            find(elem,f); // call recursively
        }
    }
}
4

1 回答 1

2

Bluebird promisify 方法适用于 NodeJS 的公认回调约定 - nodebacks。

Nodebacks 的特定格式someOp(function(err,result){是——第一个参数总是一个错误。

事实上,你的find方法甚至不是异步的,所以没有理由一开始就承诺它。您可以按原样简单地调用它。

通常,您不应该承诺同步函数,您只需正常调用它们即可。事实上,您的代码中似乎没有任何异步操作 - 所以您根本不应该在其中使用 Promise。

你可以简单地做:

mapping.value = processes[prop][property];
var value = find(processes[prop][property], function(x) {return x.$.id;});
var bpmnId = value.$.id;
console.log(value);
if(bpmnId!=undefined){
    console.log("return:"+ bpmnId);
}  

请记住,Promises 是对最终结果的抽象。就像以前一样,您将继续同步进行所有操作。

于 2014-05-12T15:01:55.207 回答