module RapidsRivers::RapidsConnection

Understands the protocol to an event bus

Public Instance Methods

publish(packet) click to toggle source
# File lib/rapids_rivers/rapids_connection.rb, line 14
def publish(packet)
  throw "No implementation to send packets: \n\t #{packet.to_s}"
end
received_message(message) click to toggle source
# File lib/rapids_rivers/rapids_connection.rb, line 10
def received_message(message)
  listeners.each { |listener| listener.message(self, message) }
end
register(listener) click to toggle source
# File lib/rapids_rivers/rapids_connection.rb, line 6
def register(listener)
  listeners << listener
end

Private Instance Methods

listeners() click to toggle source
# File lib/rapids_rivers/rapids_connection.rb, line 20
def listeners
  @listeners ||= []
end