Sha256: a0480b44a1a5b5226fb55341ef043a074124187d2508144b62a24f5a2438f685

Contents?: true

Size: 995 Bytes

Versions: 28

Compression:

Stored size: 995 Bytes

Contents

# encoding: utf-8

require 'eventmachine'
require 'mysql2'

module Mysql2
  module EM
    class Client < ::Mysql2::Client
      module Watcher
        def initialize(client, deferable)
          @client = client
          @deferable = deferable
        end

        def notify_readable
          detach
          begin
            result = @client.async_result
          rescue Exception => e
            @deferable.fail(e)
          else
            @deferable.succeed(result)
          end
        end
      end

      def close(*args)
        if @watch
          @watch.detach
        end
        super(*args)
      end

      def query(sql, opts={})
        if ::EM.reactor_running?
          super(sql, opts.merge(:async => true))
          deferable = ::EM::DefaultDeferrable.new
          @watch = ::EM.watch(self.socket, Watcher, self, deferable)
          @watch.notify_readable = true
          deferable
        else
          super(sql, opts)
        end
      end
    end
  end
end

Version data entries

28 entries across 25 versions & 2 rubygems

Version Path
mysql2-0.2.19b4 lib/mysql2/em.rb
mysql2-0.3.12b4 lib/mysql2/em.rb
mysql2-0.2.19b3 lib/mysql2/em.rb
mysql2-0.3.12b3 lib/mysql2/em.rb
mysql2-0.3.12b2 lib/mysql2/em.rb
mysql2-0.2.19b2 lib/mysql2/em.rb
mysql2-0.3.12b1 lib/mysql2/em.rb
mysql2-0.2.19b1 lib/mysql2/em.rb