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