Contents

module PipeRpc
  class Hub
    def initialize(gateway, channels)
      @channel = channels[:input]
      @socket = Socket.new(self, channels)
      @requests = Requests.new(self)
      @servers = Servers.new
      @clients = Clients.new(self)
      @transport_mapper = TransportMapper.new(gateway)
    end

    attr_reader :channel, :servers, :clients, :requests, :socket, :transport_mapper

    def handle_message
      Message.new(self, @socket.read).handle
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
pipe_rpc-2.5.0	lib/pipe_rpc/hub.rb