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

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();
}

我遇到了一些问题。

• future 返回时，仍绑定事件监听器
• future 会因为超时而返回多次

期货通常如何处理？有什么方法可以清理这些事件吗？

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
}

这将防止 done 被多次调用并删除事件侦听器。