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