class RubyEventStore::Subscriptions
Attributes
Public Class Methods
Source
# File lib/ruby_event_store/subscriptions.rb, line 7 def initialize @local = LocalSubscriptions.new @global = GlobalSubscriptions.new @thread = ThreadSubscriptions.new end
Public Instance Methods
Source
# File lib/ruby_event_store/subscriptions.rb, line 17 def add_global_subscription(subscriber) global.add(subscriber) end
Source
# File lib/ruby_event_store/subscriptions.rb, line 13 def add_subscription(subscriber, topics) local.add(subscriber, topics) end
Source
# File lib/ruby_event_store/subscriptions.rb, line 25 def add_thread_global_subscription(subscriber) thread.global.add(subscriber) end
Source
# File lib/ruby_event_store/subscriptions.rb, line 21 def add_thread_subscription(subscriber, topics) thread.local.add(subscriber, topics) end
Source
# File lib/ruby_event_store/subscriptions.rb, line 29 def all_for(topic) [local, global, thread].map { |r| r.all_for(topic) }.reduce(&:+) end