In Files

Namespace

Methods

Mysql2::EM::Client

Public Instance Methods

query(sql, opts={}) click to toggle source
# File lib/mysql2/em.rb, line 24
def query(sql, opts={})
  if ::EM.reactor_running?
    super(sql, opts.merge(:async => true))
    deferable = ::EM::DefaultDeferrable.new
    ::EM.watch(self.socket, Watcher, self, deferable).notify_readable = true
    deferable
  else
    super(sql, opts)
  end
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.