bjornbytes/RxLua
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Preserve ordering in CooperativeScheduler;

Browse Source
This commit is contained in:
bjorn 2017-05-25 16:15:49 -07:00
parent efebbf8650
commit 449e29b31c
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
rx.lua
View File

@ -1865,7 +1865,8 @@ end
function CooperativeScheduler:update(delta)
self.currentTime = self.currentTime + (delta or 0)
for i = #self.tasks, 1, -1 do
local i = 1
while i <= #self.tasks do
local task = self.tasks[i]
if self.currentTime >= task.due then
@ -1875,11 +1876,14 @@ function CooperativeScheduler:update(delta)
table.remove(self.tasks, i)
else
task.due = math.max(task.due + (delay or 0), self.currentTime)
i = i + 1
end
if not success then
error(delay)
end
else
i = i + 1
end
end
end

6
src/schedulers/cooperativescheduler.lua
View File

@ -56,7 +56,8 @@ end
function CooperativeScheduler:update(delta)
self.currentTime = self.currentTime + (delta or 0)
for i = #self.tasks, 1, -1 do
local i = 1
while i <= #self.tasks do
local task = self.tasks[i]
if self.currentTime >= task.due then
@ -66,11 +67,14 @@ function CooperativeScheduler:update(delta)
table.remove(self.tasks, i)
else
task.due = math.max(task.due + (delay or 0), self.currentTime)
i = i + 1
end
if not success then
error(delay)
end
else
i = i + 1
end
end
end