class Net::SSH::Transport::Session

def initialize(host, options = {})
  self.logger = options[:logger]
  @host = host
  @port = options[:port] || DEFAULT_PORT
  @bind_address = options[:bind_address] || nil
  @options = options
  @socket =
    if (factory = options[:proxy])
      debug { "establishing connection to #{@host}:#{@port} through proxy" }
      factory.open(@host, @port, options)
    else
      debug { "establishing connection to #{@host}:#{@port}" }
      Socket.tcp(@host, @port, @bind_address, nil,
                 connect_timeout: options[:timeout])
    end
  @socket.extend(PacketStream)
  @socket.logger = @logger
  debug { "connection established" }
  @queue = []
  @host_key_verifier = select_host_key_verifier(options[:verify_host_key])
  @server_version = ServerVersion.new(socket, logger, options[:timeout])
  @algorithms = Algorithms.new(self, options)
  @algorithms.start
  wait { algorithms.initialized? }
rescue Errno::ETIMEDOUT
  raise Net::SSH::ConnectionTimeout
end