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