1
0

effect@4.0.0-beta.101.patch 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637
  1. diff --git a/dist/Deferred.js b/dist/Deferred.js
  2. index dd5334d6e42b0881f411fca56688e639cd49c176..ea200a80d6186f07a29d0d231ff1f038433bfec3 100644
  3. --- a/dist/Deferred.js
  4. +++ b/dist/Deferred.js
  5. @@ -81,8 +81,12 @@ const _await = self => internalEffect.callback(resume => {
  6. self.resumes ??= [];
  7. self.resumes.push(resume);
  8. return internalEffect.sync(() => {
  9. + // Completion resumes every waiter and clears the array, so a cleanup
  10. + // that runs after completion (an interrupt racing the resume) has
  11. + // nothing to unregister.
  12. + if (!self.resumes) return;
  13. const index = self.resumes.indexOf(resume);
  14. - self.resumes.splice(index, 1);
  15. + if (index >= 0) self.resumes.splice(index, 1);
  16. });
  17. });
  18. export {
  19. diff --git a/src/Deferred.ts b/src/Deferred.ts
  20. index f6d37948bfbe690a7998b06c562e434e1b8ae084..da91e4dc0fd32e534fbc72f7beb0514e67e4ce74 100644
  21. --- a/src/Deferred.ts
  22. +++ b/src/Deferred.ts
  23. @@ -188,8 +188,12 @@ const _await = <A, E>(self: Deferred<A, E>): Effect<A, E> =>
  24. self.resumes ??= []
  25. self.resumes.push(resume)
  26. return internalEffect.sync(() => {
  27. - const index = self.resumes!.indexOf(resume)
  28. - self.resumes!.splice(index, 1)
  29. + // Completion resumes every waiter and clears the array, so a cleanup
  30. + // that runs after completion (an interrupt racing the resume) has
  31. + // nothing to unregister.
  32. + if (!self.resumes) return
  33. + const index = self.resumes.indexOf(resume)
  34. + if (index >= 0) self.resumes.splice(index, 1)
  35. })
  36. })