diff options
| author | Matthew Wild <mwild1@gmail.com> | 2018-03-17 14:54:48 +0000 |
|---|---|---|
| committer | Matthew Wild <mwild1@gmail.com> | 2018-03-17 14:54:48 +0000 |
| commit | 9d1d5d021bd72d872b8b4c5abd3cf3548933f930 (patch) | |
| tree | baddae87b7a48b7cdbc752e40f1e99d924bb7fad /util/async.lua | |
| parent | 3802dc1555643ca6ab57593c47457346ab11ca98 (diff) | |
| download | prosody-9d1d5d021bd72d872b8b4c5abd3cf3548933f930.tar.gz prosody-9d1d5d021bd72d872b8b4c5abd3cf3548933f930.zip | |
util.async: Behaviour change: continue to process queued items after errors
Diffstat (limited to 'util/async.lua')
| -rw-r--r-- | util/async.lua | 3 |
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 |