mirrors/prosody
1
0
Fork 0
mirror of https://github.com/bjc/prosody.git synced 2025-04-04 13:47:41 +03:00
Code Issues Projects Releases Packages Wiki Activity Actions

util.queue: Add :items() iterator

Browse source
This commit is contained in:
Matthew Wild 2015-10-18 21:42:33 +01:00
parent 0b394fbeb9
commit cd8af079c3
1 changed files with 13 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

13
util/queue.lua
View file

@ -18,6 +18,7 @@ local function new(size, allow_wrapping)
local t = have_utable and utable.create(size, 0) or {}; -- Table to hold items local t = have_utable and utable.create(size, 0) or {}; -- Table to hold items
return { return {
_items = t;
size = size; size = size;
count = function (self) return items; end; count = function (self) return items; end;
push = function (self, item) push = function (self, item)
@ -50,6 +51,18 @@ local function new(size, allow_wrapping)
end end
return t[tail]; return t[tail];
end; end;
items = function (self)
return function (t, pos)
if pos >= t:count() then
return nil;
end
local read_pos = tail + pos;
if read_pos > t.size then
read_pos = (read_pos%size);
end
return pos+1, t._items[read_pos];
end, self, 0;
end;
}; };
end end