class RubyEventStore::Subscriptions::LocalSubscriptions
Public Class Methods
Source
# File lib/ruby_event_store/subscriptions.rb, line 50 def initialize @subscriptions = Hash.new { |hsh, key| hsh[key] = [] } end
Public Instance Methods
Source
# File lib/ruby_event_store/subscriptions.rb, line 54 def add(subscription, topics) topics.each { |topic| @subscriptions[topic] << subscription } -> { topics.each { |topic| @subscriptions.fetch(topic).delete(subscription) } } end
Source
# File lib/ruby_event_store/subscriptions.rb, line 59 def all_for(topic) @subscriptions[topic] end