Sovereignty/luau-promise
1
0
Fork 0
mirror of https://github.com/AmberGraceRblx/luau-promise.git synced 2025-04-24 23:50:03 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Pass error to executor runner

Browse source
This commit is contained in:
Eryn Lynn 2020-02-12 19:59:04 -05:00
parent 87937962ad
commit 64ba0099f1
1 changed files with 5 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
lib/init.lua
View file

@ -35,7 +35,7 @@ end
Handles errors if they happen. Handles errors if they happen.
]] ]]
local function ppcall(yieldError, callback, ...) local function runExecutor(yieldError, traceback, callback, ...)
-- Wrapped because C functions can't be passed to coroutine.create! -- Wrapped because C functions can't be passed to coroutine.create!
local co = coroutine.create(function(...) local co = coroutine.create(function(...)
return callback(...) return callback(...)
@ -44,7 +44,7 @@ local function ppcall(yieldError, callback, ...)
local ok, len, result = packResult(coroutine.resume(co, ...)) local ok, len, result = packResult(coroutine.resume(co, ...))
if ok and coroutine.status(co) ~= "dead" then if ok and coroutine.status(co) ~= "dead" then
error(yieldError, 2) error(yieldError .. "\n" .. traceback, 2)
end end
return ok, len, result return ok, len, result
@ -56,7 +56,7 @@ end
]] ]]
local function createAdvancer(traceback, callback, resolve, reject) local function createAdvancer(traceback, callback, resolve, reject)
return function(...) return function(...)
local ok, resultLength, result = ppcall(ERROR_YIELD_THEN, callback, ...) local ok, resultLength, result = runExecutor(ERROR_YIELD_THEN, traceback, callback, ...)
if ok then if ok then
resolve(unpack(result, 1, resultLength)) resolve(unpack(result, 1, resultLength))
@ -165,8 +165,9 @@ function Promise.new(callback, parent)
return self._status == Promise.Status.Cancelled return self._status == Promise.Status.Cancelled
end end
local ok, _, result = ppcall( local ok, _, result = runExecutor(
ERROR_YIELD_NEW, ERROR_YIELD_NEW,
self._source,
callback, callback,
resolve, resolve,
reject, reject,