aboutsummaryrefslogtreecommitdiffstats
path: root/util
diff options
context:
space:
mode:
authorMatthew Wild <mwild1@gmail.com>2018-03-17 14:54:48 +0000
committerMatthew Wild <mwild1@gmail.com>2018-03-17 14:54:48 +0000
commit9d1d5d021bd72d872b8b4c5abd3cf3548933f930 (patch)
treebaddae87b7a48b7cdbc752e40f1e99d924bb7fad /util
parent3802dc1555643ca6ab57593c47457346ab11ca98 (diff)
downloadprosody-9d1d5d021bd72d872b8b4c5abd3cf3548933f930.tar.gz
prosody-9d1d5d021bd72d872b8b4c5abd3cf3548933f930.zip
util.async: Behaviour change: continue to process queued items after errors
Diffstat (limited to 'util')
-rw-r--r--util/async.lua3
1 files changed, 3 insertions, 0 deletions
diff --git a/util/async.lua b/util/async.lua
index 0dde1f32..8756c81a 100644
--- a/util/async.lua
+++ b/util/async.lua
@@ -180,6 +180,9 @@ function runner_mt:run(input)
local handler = self.watchers[state];
if handler then handler(self, err); end
end
+ if n > 0 then
+ return self:run();
+ end
return true, state, n;
end