Contents

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.1	lib/em-synchrony/em-mysql.rb