module ActionPubsub::ActiveRecord::WithConnection::ClassMethods

Public Instance Methods

on(*paths, as:nil, &block) click to toggle source
# File lib/action_pubsub/active_record/with_connection.rb, line 7
def on(*paths, as:nil, &block)
  wrapped_block = lambda{ |message|
    ::ActiveRecord::Base.connection_pool.with_connection { block.call(message) }
  }

  _subscriptions = ::ActionPubsub.on(*paths, as:(as || _as), &wrapped_block)
  _subscriptions.each { |_subscription| subscriptions << _subscription }
  subscriptions
end