refactor: coroutine resume to bubble up errors

permaweb · Oct 17, 2024 · 3153e94 · 3153e94
1 parent c883591
commit 3153e94
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/process/handlers.lua b/process/handlers.lua
@@ -59,7 +59,11 @@ end
 function handlers.receive(pattern)
   local self = coroutine.running()
   handlers.once(pattern, function (msg)
-      coroutine.resume(self, msg)
+      -- If the result of the resumed coroutine is an error then we should bubble it up to the process
+      local _, success, errmsg = coroutine.resume(self, msg)
+      if not success then
+        error(errmsg)
+      end
   end)
   return coroutine.yield(pattern)
 end