mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-05 06:07: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 5303e72605
commit a8f9a2757f
2 changed files with 27 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

20
spec/util_async_spec.lua
View file

@ -94,6 +94,26 @@ describe("util.async", function()
assert.equal(last_item, values[#values]); assert.equal(last_item, values[#values]);
end); end);
it("should work with no parameters", function ()
local item = "fail";
local r = async.runner();
local f = spy.new(function () item = "success"; end);
r:run(f);
assert.spy(f).was.called();
assert.equal(item, "success");
end);
it("supports a default error handler", function ()
local item = "fail";
local r = async.runner();
local f = spy.new(function () error("test error"); end);
assert.error_matches(function ()
r:run(f);
end, "test error");
assert.spy(f).was.called();
assert.equal(item, "fail");
end);
describe("#errors", function () describe("#errors", function ()
describe("should notify", function () describe("should notify", function ()
local last_processed_item, last_error; local last_processed_item, last_error;

10
util/async.lua
View file

@ -130,10 +130,14 @@ local function runner_create_thread(func, self)
return thread; return thread;
end 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) local function runner(func, watchers, data)
return setmetatable({ func = func, thread = false, state = "ready", notified_state = "ready", return setmetatable({ func = func or default_func, thread = false, state = "ready", notified_state = "ready",
queue = {}, watchers = watchers or empty_watchers, data = data, id = new_id() } queue = {}, watchers = watchers or { error = default_error_watcher }, data = data, id = new_id() }
, runner_mt); , runner_mt);
end end