Class: Replay::Router::DefaultRouter

Inherits:
Object
  • Object
show all
Includes:
Singleton
Defined in:
lib/replay/router/default_router.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ DefaultRouter

Returns a new instance of DefaultRouter.



6
7
8
 
# File 'lib/replay/router/default_router.rb', line 6

def initialize
  @subscription_manager = Replay::SubscriptionManager.new
end

Instance Method Details

#add_observer(observer, *events) ⇒ Object 



10
11
12
 
# File 'lib/replay/router/default_router.rb', line 10

def add_observer(observer, *events)
  @subscription_manager.add_subscriber(observer)
end

#published(stream_id, event) ⇒ Object 



14
15
16
 
# File 'lib/replay/router/default_router.rb', line 14

def published(stream_id, event)
  @subscription_manager.notify_subscribers(stream_id, event)
end