Mysql2::Fibered::Client::Watcher

    # File lib/active_record/connection_adapters/em_mysql2_adapter.rb, line 27
27:         def initialize(client, deferable)
28:           @client = client
29:           @deferable = deferable
30:         end

    # File lib/active_record/connection_adapters/em_mysql2_adapter.rb, line 32
32:         def notify_readable
33:           begin
34:             detach
35:             results = @client.async_result
36:             @deferable.succeed(results)
37:           rescue Exception => e
38:             puts e.backtrace.join("\n\t")
39:             @deferable.fail(e)
40:           end
41:         end