module FutureRecords::FutureFeature

Public Instance Methods

records() click to toggle source
Calls superclass method
# File lib/future_records.rb, line 21
def records
  @query_thread.join
  @records
rescue ::ActiveRecord::ConnectionTimeoutError
  logger.info 'FutureRecords: Failed to obtain a connection. Falling back to non-threaded query'
  method(:exec_queries).super_method.call
  super
end

Private Instance Methods

exec_queries(&block) click to toggle source
Calls superclass method
# File lib/future_records.rb, line 13
        def exec_queries(&block)
  @query_thread = Thread.new do
    connection_pool.with_connection do
      super
    end
  end
end