Contents

# frozen_string_literal: true

module Anycable
  module Rails
    module ActiveRecord
      # Release ActiveRecord connection after every call (if any)
      module ReleaseConnection
        def connect(*)
          wrap_release_connection { super }
        end

        def disconnect(*)
          wrap_release_connection { super }
        end

        def command(*)
          wrap_release_connection { super }
        end

        def wrap_release_connection
          res = yield
          ::ActiveRecord::Base.connection_pool.release_connection if
            ::ActiveRecord::Base.connection_pool.active_connection?
          res
        end
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
anycable-rails-0.5.5	lib/anycable/rails/activerecord/release_connection.rb
anycable-rails-0.5.4	lib/anycable/rails/activerecord/release_connection.rb
anycable-rails-0.5.3	lib/anycable/rails/activerecord/release_connection.rb
anycable-rails-0.5.2	lib/anycable/rails/activerecord/release_connection.rb
anycable-rails-0.5.1	lib/anycable/rails/activerecord/release_connection.rb
anycable-rails-0.5.0	lib/anycable/rails/activerecord/release_connection.rb
anycable-rails-0.5.0.rc2	lib/anycable/rails/activerecord/release_connection.rb
anycable-rails-0.5.0.rc1	lib/anycable/rails/activerecord/release_connection.rb
anycable-rails-0.4.7	lib/anycable/rails/activerecord/release_connection.rb