蓝鸟取消等待

Question

此代码工作正常：

let promise;
try {
    promise = parent();
    //but I want: await parent();
    await continueStack();
} catch (e) {
    console.log('Caught error in endpoint');
}

eventBus.on('stop::all', () => {
    console.warn('Caught stop::all event');
    promise.cancel();
});

它正在取消对程序其他部分发出的事件的承诺。我的问题是我不能拥有await parent()，因为那时还没有执行监听事件。如果我改成这样：

let promise;
eventBus.on('stop::all', () => {
    console.warn('Caught stop::all event');
    promise.cancel();
});

try {
    promise = await parent();
    await continueStack();
} catch (e) {
    console.log('Caught error in endpoint');
}

那我有错误

TypeError: 无法读取未定义的属性“取消”

它崩溃了，continueStack() 永远不会被执行。我想如何调和这些？

---

我已经用上面的场景创建了整个示例：

https://gist.github.com/BorysTyminski/147dc2e0c44c8d64386253d563ff6db4

为了运行它，你需要获取这两个文件，安装 package.json 依赖并运行 cURL / Postman request GET to localhost:5000/test

Answer 1

您可以通过将promise var 设置为parent 来做到这一点，然后等待它：

const EventEmitter = require('events');
const Promise = require('bluebird');

Promise.config({
  cancellation: true,
})
const parent = new Promise(resolve => {
  setTimeout( () => {
    resolve();
  }, 100);
});

const continueStack = new Promise(resolve => {
  setTimeout( () => {
    resolve();
  }, 100);
});

let promise;

const emitter = new EventEmitter();

emitter.on('stop', function() {
  if(promise && promise.cancel){
    promise.cancel();
    console.log('promise cancelled');
  } else {
    console.log('somehow promise was not properly set at this point');
  }
});

setTimeout(_ => {
  emitter.emit('stop');
}, 80);

async function operation() {
  try {
  promise = parent;
  await promise;
  console.log('after promise. This log should never appear.');
  await continueStack;
    console.log('after wait 2. This log should never appear.');
  } catch(e) {
    console.log('Even if the promise is cancelled, this is not called.');
  }
}

operation();

（使用节点运行 sn-p 只会记录“已取消承诺”）：在异步函数内部执行 await promise 之后什么都没有。

一些注意事项：

• 需要Promise.config 将cancellable 设置为true。

• await 不像睡眠。它不会阻塞 javascript 线程、事件侦听器或任何事件发射器。它只是确保await 之后的代码将等待等待的承诺。但这仅在异步函数的上下文中。

• 取消 Promise 不会触发 catch 处理程序。这让我很困惑，但我想这就是它的工作原理。