Sha256: 96ab483017c4e435e53b71a9c77a6d1467d20b0e9352ab8f11b80143e59cb0c5
Contents?: true
Size: 707 Bytes
Versions: 31
Compression:
Stored size: 707 Bytes
Contents
# https://github.com/eventmachine/eventmachine/pull/929 is not released yet.
# i will delete this patch if released.
module EventMachine
# @private
class Reactor
def run_timers
timers_to_delete = []
@timers.each {|t|
if t.first <= @current_loop_time
#@timers.delete t
timers_to_delete << t
EventMachine::event_callback "", TimerFired, t.last
else
break
end
}
timers_to_delete.map{|c| @timers.delete c}
timers_to_delete = nil
#while @timers.length > 0 and @timers.first.first <= now
# t = @timers.shift
# EventMachine::event_callback "", TimerFired, t.last
#end
end
end
end
Version data entries
31 entries across 31 versions & 1 rubygems