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