Software /
code /
prosody
Changeset
8683:867ac771fb6e
util.async: Remove async.once(), can now be replaced by runner():run(func)
author | Matthew Wild <mwild1@gmail.com> |
---|---|
date | Fri, 23 Mar 2018 14:22:01 +0000 |
parents | 8682:151ecd18d624 |
children | 8684:801f253ef52d |
files | spec/util_async_spec.lua util/async.lua |
diffstat | 2 files changed, 0 insertions(+), 33 deletions(-) [+] |
line wrap: on
line diff
--- a/spec/util_async_spec.lua Fri Mar 23 14:18:27 2018 +0000 +++ b/spec/util_async_spec.lua Fri Mar 23 14:22:01 2018 +0000 @@ -613,23 +613,4 @@ assert.spy(r.watchers.error).was_not.called(); end); end); - - describe("#once()", function () - it("should work", function () - local f = spy.new(function () - assert.truthy(async.ready()); - end); - async.once(f); - assert.spy(f).was.called(); - assert.spy(f).was.called_with(); - end); - it("should propagate errors", function () - local function should_error() - async.once(function () - error("hello world"); - end); - end; - assert.error_matches(should_error, "hello world"); - end); - end); end);
--- a/util/async.lua Fri Mar 23 14:18:27 2018 +0000 +++ b/util/async.lua Fri Mar 23 14:22:01 2018 +0000 @@ -226,20 +226,6 @@ return pcall(checkthread); end -local once; -- forward declaration -do - local once_watchers = { - error = function (_, err) - error(err); - end; - }; - local function once_runner(func) func(); end - function once(func) - local r = runner(once_runner, once_watchers); - return r:run(func); - end -end - local function sleep(s) local wait, done = waiter(); timer.add_task(s, done);