# HG changeset patch # User Matthew Wild # Date 1525089233 -3600 # Node ID 01264bc60c2b7cdcdc563df56e3d37659932d5cb # Parent d5ff0982d3e633fbf3e9bc9e4c3a5e5e8dd9872e util.async: Add helper methods for setting watchers diff -r d5ff0982d3e6 -r 01264bc60c2b util/async.lua --- a/util/async.lua Sun Apr 29 22:15:44 2018 +0100 +++ b/util/async.lua Mon Apr 30 12:53:53 2018 +0100 @@ -215,12 +215,28 @@ function runner_mt:enqueue(input) table.insert(self.queue, input); self:log("debug", "queued new work item, %d items queued", #self.queue); + return self; end function runner_mt:log(level, fmt, ...) return log(level, "[runner %s] "..fmt, self.id, ...); end +function runner_mt:onready(f) + self.watchers.ready = f; + return self; +end + +function runner_mt:onwaiting(f) + self.watchers.waiting = f; + return self; +end + +function runner_mt:onerror(f) + self.watchers.error = f; + return self; +end + local function ready() return pcall(checkthread); end