Sha256: 5e30f07fc00225c3b7a158c0b83a89d8cdf8198866482e25a5a18fe809cb8773
Contents?: true
Size: 382 Bytes
Versions: 11
Compression:
Stored size: 382 Bytes
Contents
module PipeRpc
class Hub
def initialize(args)
@channel = args[:input]
@socket = Socket.new(self, args)
@requests = Requests.new(self)
@servers = Servers.new
@clients = Clients.new(self)
end
attr_reader :channel, :servers, :clients, :requests, :socket
def handle_message
Message.new(self, @socket.read).handle
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems