Sha256: 74d02ed66b129791dba73d7dbc40256b206194fcad51c2e122b3e1ec2d166e25
Contents?: true
Size: 1.14 KB
Versions: 24
Compression:
Stored size: 1.14 KB
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 @is_watching = true end def notify_readable detach begin result = @client.async_result rescue Exception => e @deferable.fail(e) else @deferable.succeed(result) end end def watching? @is_watching end def unbind @is_watching = false end end def close(*args) if @watch @watch.detach if @watch.watching? 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
24 entries across 24 versions & 3 rubygems