class Async::Postgres::Proxy
Public Class Methods
new(connection_string, task: Task.current)
click to toggle source
# File lib/async/postgres/pool.rb, line 30 def initialize(connection_string, task: Task.current) @connection_string = connection_string pools = task.reactor.postgres_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/postgres/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/postgres/pool.rb, line 40 def close @pool.close end
method_missing(*args, &block)
click to toggle source
# File lib/async/postgres/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/postgres/pool.rb, line 50 def respond_to?(*args) @pool.acquire do |connection| connection.respond_to?(*args) end end