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