Mysql2::Fibered::Client

    # File lib/active_record/connection_adapters/em_mysql2_adapter.rb, line 44
44:       def query(sql, opts={})
45:         if EM.reactor_running?
46:           super(sql, opts.merge(:async => true))
47:           deferable = ::EM::DefaultDeferrable.new
48:           ::EM.watch(self.socket, Watcher, self, deferable).notify_readable = true
49:           fiber = Fiber.current
50:           deferable.callback do |result|
51:             fiber.resume(result)
52:           end
53:           deferable.errback do |err|
54:             fiber.resume(err)
55:           end
56:           Fiber.yield
57:         else
58:           super(sql, opts)
59:         end
60:       end