Method: ActiveRecord::FutureResult::EventBuffer#flush

Defined in:
activerecord/lib/active_record/future_result.rb

#flush ⇒ Object 



42
43
44
45
46
47
48
 
# File 'activerecord/lib/active_record/future_result.rb', line 42

def flush
  events, @events = @events, []
  events.each do |event|
    event.payload[:lock_wait] = @future_result.lock_wait
    ActiveSupport::Notifications.publish_event(event)
  end
end