Contents

begin
  require "em-mysqlplus"
rescue LoadError => error
  raise "Missing EM-Synchrony dependency: gem install em-mysqlplus"
end

module EventMachine
  class MySQL

    alias :aquery :query
    def query(sql, &blk)
      f = Fiber.current

      # TODO: blk case does not work. Hmm?
      cb = Proc.new { |r| f.resume(r) }
      eb = Proc.new { |r| f.resume(r) }

      @connection.execute(sql, cb, eb)

      Fiber.yield
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
em-synchrony-0.1.5	lib/em-synchrony/em-mysqlplus.rb