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