Comparison

util.async: Add helper methods for setting watchers

comparison

equal deleted inserted replaced

-:d5ff0982d3e6
+:01264bc60c2b
 -- Add a task item to the queue without invoking the runner, even if it is idle
 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