Class: RubyEventStore::PubSub::Subscriptions::GlobalSubscriptions

Inherits:
Object
  • Object
show all
Defined in:
lib/ruby_event_store/pub_sub/subscriptions.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ GlobalSubscriptions

Returns a new instance of GlobalSubscriptions.



63
64
65
 
# File 'lib/ruby_event_store/pub_sub/subscriptions.rb', line 63

def initialize
  @subscriptions = []
end

Instance Method Details

#add(subscription) ⇒ Object 



67
68
69
70
 
# File 'lib/ruby_event_store/pub_sub/subscriptions.rb', line 67

def add(subscription)
  @subscriptions << subscription
  ->() { @subscriptions.delete(subscription) }
end

#all_for(_event_type) ⇒ Object 



72
73
74
 
# File 'lib/ruby_event_store/pub_sub/subscriptions.rb', line 72

def all_for(_event_type)
  @subscriptions
end