class RubyEventStore::Subscriptions::GlobalSubscriptions
Public Class Methods
Source
# File lib/ruby_event_store/subscriptions.rb, line 65 def initialize @subscriptions = [] end
Public Instance Methods
Source
# File lib/ruby_event_store/subscriptions.rb, line 69 def add(subscription) @subscriptions << subscription -> { @subscriptions.delete(subscription) } end
Source
# File lib/ruby_event_store/subscriptions.rb, line 74 def all_for(_topic) @subscriptions end