diff options
Diffstat (limited to 'queue.lua')
| -rw-r--r-- | queue.lua | 8 |
1 files changed, 4 insertions, 4 deletions
@@ -1,15 +1,15 @@ local cqueues = require'cqueues' local condition = require'cqueues.condition' local cqaux = require'cqueues.auxlib' +local class = require 'r.class' -local Queue = {} +local Queue = class() -function Queue.make() +function Queue.make(cls) return setmetatable({ items = {}, cv = condition.new(), - }, {__index=Queue}) -end + }, cls) end function Queue.enqueue(self, ...) local item = table.pack(...) |
