如何用超时和监听器创建未来

Question

我正在尝试创建一个具有未来的功能。在此功能中，它将等待End或Error事件。如果没有数据写入x秒，它将返回一个错误。这是我写的。

Cylon.execute = function (subroutine, timeout=60000) { 
    let future = new Future(); 
    let done = future.resolver(); 

    let timeoutId = Meteor.setTimeout(function() { 
    done(new Meteor.Error('CylonTimeout')); 
    }); 
    this._messages.on('data',() => { 
    timeoutId = Meteor.setTimeout(function() { 
     done(new Meteor.Error('CylonTimeout')); 
    }); 
    }); 
    this.on('End',() => { 
    Meteor.clearTimeout(timeoutId); 
    done(null, subroutine); 
    }) 
    this.on('Error', (err) => { 
    Meteor.clearTimeout(timeoutId) 
    done(err, null) 
    }); 
    this._commands.write(`Execute #${subroutine}\r`, 'utf8'); 
    return future.wait(); 
} 

我遇到了一些问题。

• 当未来的回报，该事件侦听器仍结合
• 未来可以因为超时

这是如何通常与期货的处理返回多次？有没有办法清理这些事件？

Answer 1

首先我建议你做this.once而不是this.on，这样你只会触发事件处理程序一次。 没有必要多次触发它。

此外，我建议你做

var self = this; 
done = function (err, result) { 
    //remove all listeners 
    self.removeListener('Error', handler); 
    //.... and so on.... 

    future.resolver()(err, result);//call actual done 
} 

这将防止被调用一次以上的完成和删除事件侦听器。