javascript - Kue作业完成后执行回调

Question

我见过类似 this 的问题但他们没有回答我的问题。

我有一个函数

var kue = require('kue');
var jobs = kue.createQueue();

var create_job = function(data, callback){
    jobs.create('job', {
        stuff: data   
    }).save();
}

我怎样才能让它在 jobs.process('job', function(job, done){ ... 完成时调用 callback？

Answer 1

我以前没有使用过 kue，所以这是他们的文档:

var kue = require('kue');
var jobs = kue.createQueue();

var create_job = function(data, callback){
    var job = jobs.create('job', {
        stuff: data   
    }).save();
    job.on('complete', function(){
        callback();
    }).on('failed', function(){
      callback({error: true});
    });    
};

我已经创建/使用了一个 JavaScript 闭包来捕获 callback 参数的值(通过将事件附加到 create_job 函数的范围内，稍后在函数完成(或失败)时调用。