class PipeRpc::Hub

Attributes

channel[R]
clients[R]
requests[R]
servers[R]
socket[R]
transport_mapper[R]

Public Class Methods

new(gateway, channels) click to toggle source
# File lib/pipe_rpc/hub.rb, line 3
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

Public Instance Methods

handle_message() click to toggle source
# File lib/pipe_rpc/hub.rb, line 14
def handle_message
  Message.new(self, @socket.read).handle
end