class Async::MySQL::Proxy

Public Class Methods

new(connection_string, task: Task.current) click to toggle source
# File lib/async/mysql/pool.rb, line 30
def initialize(connection_string, task: Task.current)
        @connection_string = connection_string
        
        pools = task.reactor.mysql_pools ||= {}
        
        @pool = pools[@connection_string] ||= Pool.new do
                Connection.new(@connection_string)
        end
end

Public Instance Methods

async_exec(*args) click to toggle source
# File lib/async/mysql/pool.rb, line 44
def async_exec(*args)
        @pool.acquire do |connection|
                connection.async_exec(*args)
        end
end
close() click to toggle source
# File lib/async/mysql/pool.rb, line 40
def close
        @pool.close
end
method_missing(*args, &block) click to toggle source
# File lib/async/mysql/pool.rb, line 56
def method_missing(*args, &block)
        @pool.acquire do |connection|
                connection.send(*args, &block)
        end
end
respond_to?(*args) click to toggle source
# File lib/async/mysql/pool.rb, line 50
def respond_to?(*args)
        @pool.acquire do |connection|
                connection.respond_to?(*args)
        end
end