Class: Observed::BasicEventBus

Inherits:

Object

• Object
• Observed::BasicEventBus

Defined in:

lib/observed/basic_event_bus.rb

Instance Method Summary

• #emit(tag, *params) ⇒ Object
• #initialize ⇒ BasicEventBus constructor

  A new instance of BasicEventBus.

• #on_receive(pattern, &block) ⇒ Object

Constructor Details

#initialize ⇒ BasicEventBus

Returns a new instance of BasicEventBus.

# File 'lib/observed/basic_event_bus.rb', line 6

def initialize
  @monitor = ::Monitor.new
  @subscribers = []
end

Instance Method Details

#emit(tag, *params) ⇒ Object

# File 'lib/observed/basic_event_bus.rb', line 10

def emit(tag, *params)
  handle_event(tag, *params)
end

#on_receive(pattern, &block) ⇒ Object

# File 'lib/observed/basic_event_bus.rb', line 14

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