mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-05 14:17:37 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

util.async: Make parameters to async.runner() optional

Browse source
This commit is contained in:
Matthew Wild 2018-03-23 14:02:33 +00:00
parent faea440e51
commit 8a38579fa0
2 changed files with 27 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
util/async.lua
View file

@ -130,10 +130,14 @@ local function runner_create_thread(func, self)
return thread;
end
local empty_watchers = {};
local function default_error_watcher(runner, err)
runner:log("error", "Encountered error: %s", err);
error(err);
end
local function default_func(f) f(); end
local function runner(func, watchers, data)
return setmetatable({ func = func, thread = false, state = "ready", notified_state = "ready",
queue = {}, watchers = watchers or empty_watchers, data = data, id = new_id() }
return setmetatable({ func = func or default_func, thread = false, state = "ready", notified_state = "ready",
queue = {}, watchers = watchers or { error = default_error_watcher }, data = data, id = new_id() }
, runner_mt);
end