Module: Smith::Events

Defined in:

lib/smith/events.rb,
lib/smith/events/bus.rb,
lib/smith/events/subscription.rb,
lib/smith/events/step_completed.rb

Defined Under Namespace

Classes: Scope, StepCompleted, Subscription

Class Method Summary

• .emit(event) ⇒ Object
• .on(event_class, **opts, &block) ⇒ Object
• .reset! ⇒ Object
• .subscriptions ⇒ Object
• .within ⇒ Object

Class Method Details

.emit(event) ⇒ Object

# File 'lib/smith/events/bus.rb', line 32

def emit(event)
  subscriptions.each { |sub| dispatch_to(sub, event) }
end

.on(event_class, **opts, &block) ⇒ Object

# File 'lib/smith/events/bus.rb', line 26

def on(event_class, **opts, &block)
  sub = Subscription.new(event_class, handler: block, predicate: opts[:if])
  subscriptions << sub
  sub
end

.reset! ⇒ Object

# File 'lib/smith/events/bus.rb', line 43

def reset!
  @subscriptions = []
end

.subscriptions ⇒ Object

# File 'lib/smith/events/bus.rb', line 22

def subscriptions
  @subscriptions ||= []
end

.within ⇒ Object

# File 'lib/smith/events/bus.rb', line 36

def within
  scope = Scope.new
  yield scope
ensure
  scope&.cancel_all
end