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

util.async: Behaviour change: continue to process queued items after errors

Browse source
This commit is contained in:
Matthew Wild 2018-03-17 14:54:48 +00:00
parent 7d562e915e
commit 3148c6b4f7
2 changed files with 27 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

24
spec/util_async_spec.lua
View file

@ -156,6 +156,30 @@ describe("util.async", function()
assert.equal(r.state, "ready");
assert.equal(last_processed_item, "hello again");
end);
it("should continue to process work items", function ()
local wait, done, last_item;
local runner_func = spy.new(function (item)
if item == "error" then
error("test error");
elseif item == "wait-error" then
wait, done = async.waiter();
wait();
error("test error");
end
last_item = item;
end);
local runner = async.runner(runner_func, { error = spy.new(function () end) });
runner:enqueue("one");
runner:enqueue("error");
runner:enqueue("two");
runner:run();
assert.equal(r.state, "ready");
assert.equal(r.state, r.notified_state);
assert.spy(runner_func).was.called(3);
assert.spy(runner.watchers.error).was.called(1);
assert.equal(last_item, "two");
end);
end);
end);
describe("#waiter", function()