class Fyrehose::TCPClient
Public Instance Methods
parse_response(str)
click to toggle source
# File lib/fyrehose/tcp_client.rb, line 14 def parse_response(str) raise Fyrehose::ConnectionError.new unless str m = str.match(/#[^ ]+ \$([0-9]+)\n/) raise Fyrehose::ProtocolError.new unless m m[1].to_i end
send_data(data)
click to toggle source
# File lib/fyrehose/tcp_client.rb, line 3 def send_data(data) Timeout::timeout(@timeout) do @sock = TCPSocket.new(@host, @port) unless @sock @sock.send(data, 0) parse_response(@sock.gets) end rescue Exception => e @sock = nil raise e end