Method: Observed::BasicEventBus#on_receive

Defined in:
lib/observed/basic_event_bus.rb

#on_receive(pattern, &block) ⇒ Object 



14
15
16
17
18
 
# File 'lib/observed/basic_event_bus.rb', line 14

def on_receive(pattern, &block)
  @monitor.synchronize do
    @subscribers.push [pattern, block]
  end
end