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