Contents

module RapidsRivers

  # Understands the protocol to an event bus
  module RapidsConnection

    def register(listener)
      listeners << listener
    end

    def received_message(message)
      listeners.each { |listener| listener.message(self, message) }
    end

    def publish(packet)
      throw "No implementation to send packets: \n\t #{packet.to_s}"
    end

    private

      def listeners
        @listeners ||= []
      end

  end

end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
rapids_rivers-0.2.16	lib/rapids_rivers/rapids_connection.rb
rapids_rivers-0.2.14	lib/rapids_rivers/rapids_connection.rb
rapids_rivers-0.2.9	lib/rapids_rivers/rapids_connection.rb
rapids_rivers-0.1.7	lib/rapids_rivers/rapids_connection.rb