class Railjet::Bus
Constants
- VERSION
Attributes
adapter[RW]
bus[R]
Public Class Methods
new(adapter: self.class.adapter)
click to toggle source
# File lib/railjet/bus.rb, line 23 def initialize(adapter: self.class.adapter) @bus = adapter or raise ArgumentError, "Railjet::Bus adapter must be specified" end
Public Instance Methods
subscribe(event, subscriber)
click to toggle source
# File lib/railjet/bus.rb, line 27 def subscribe(event, subscriber) bus.subscribe(subscriber, on: event, prefix: true, async: true) end
subscribe_listener(listener)
click to toggle source
# File lib/railjet/bus.rb, line 31 def subscribe_listener(listener) listener.subscriptions.each do |event| subscribe(event, listener) end end