class Yajl::HttpStream

def initialize_socket(uri, opts = {})

Initialize socket and add it to the opts
def initialize_socket(uri, opts = {})
  return if opts[:socket]
  @socket = TCPSocket.new(uri.host, uri.port)
  opts.merge!({:socket => @socket})
  @intentional_termination = false
end