class EM::Synchrony::ActiveRecord::ConnectionPool

def affected_rows(*args, &blk)

via method_missing affected_rows will be recognized as async method
def affected_rows(*args, &blk)
  execute(false) do |conn|
    conn.send(:affected_rows, *args, &blk)
  end
end