lib/nestene/actor/delayed_scheduler.rb in nestene-0.2.0 vs lib/nestene/actor/delayed_scheduler.rb in nestene-0.2.1

- old
+ new

@@ -20,16 +20,19 @@ def update_schedule topic, auton_id, state @schedule.delete_if{|e| e.first == auton_id} - state.queue.delayed.each do |d| - @schedule << [auton_id, d] - end + if state - @schedule.sort_by!{|e| e[1].execute_at} + state.queue.delayed.each do |d| + @schedule << [auton_id, d] + end - async.schedule_methods + @schedule.sort_by!{|e| e[1].execute_at} + + async.schedule_methods + end end def schedule_methods