PromiseWaiter.js 833 B

1234567891011121314151617181920212223242526272829303132333435363738394041
  1. /**
  2. * Wait for multiple Promises to resolve.
  3. */
  4. module.exports = class PromiseWaiter {
  5. constructor () {
  6. this.promises = []
  7. }
  8. add (promise) {
  9. this.promises.push(promise)
  10. const remove = () => {
  11. this.remove(promise)
  12. }
  13. promise.then(remove, remove)
  14. }
  15. remove (promise) {
  16. const index = this.promises.indexOf(promise)
  17. if (index !== -1) {
  18. this.promises.splice(index, 1)
  19. }
  20. }
  21. wait () {
  22. const promises = this.promises
  23. this.promises = []
  24. function noop () {
  25. // No result value
  26. }
  27. // Just wait for a Promise to conclude in some way, whether it's resolution
  28. // or rejection. We don't care about the contents.
  29. function concluded (promise) {
  30. return promise.then(noop, noop)
  31. }
  32. return Promise.all(promises.map(concluded)).then(noop)
  33. }
  34. }