# File lib/mysql2/em.rb, line 25
      def query(sql, opts={})
        super(sql, opts.merge(:async => true))
        deferable = ::EM::DefaultDeferrable.new
        ::EM.watch(self.socket, Watcher, self, deferable).notify_readable = true
        deferable
      end