```ruby
class FlyingSphinx::Tunnel
  def self.connect(configuration, &block)
    tunnel = new configuration
    tunnel.open do |session|
      session.loop do
        puts "Channel Count: #{session.channels.count}"
        block.call
      end
    end
  end

  def initialize(configuration)
    @configuration = configuration
  end

  def open(&block)
    session = Net::SSH.start(@configuration.host, 'sphinx', ssh_options)
    session.forward.remote(
      db_port, db_host, @configuration.database_port, '0.0.0.0'
    )

    session.loop { !remote_exists?(session) }

    yield session
    session.close unless session.closed?
  ensure
    session.shutdown unless session.closed?
  end

  private

  def db_host
    db_config[:host]
  end

  def db_port
    db_config[:port]
  end

  def db_config
    @db_config ||= ActiveRecord::Base.connection.instance_variable_get(:@config)
  end

  def ssh_options
    {:keys => [
      File.expand_path('../../../keys/key', __FILE__)
    ]}
  end

  def remote_exists?(session)
    session.forward.active_remotes.include?(
      [@configuration.database_port, '0.0.0.0']
    )
  end
end
```

Stop looping when the session is quiet (port forward no longer exists).
user
```ruby
class FlyingSphinx::Tunnel
  def self.connect(configuration, &block)
    tunnel = new configuration
    tunnel.open do |session|
      session.loop do
        return false unless session.busy?(true)
        block.call
      end
    end
  end

  def initialize(configuration)
    @configuration = configuration
  end

  def open(&block)
    session = Net::SSH.start(@configuration.host, 'sphinx', ssh_options)
    session.forward.remote(
      db_port, db_host, @configuration.database_port, '0.0.0.0'
    )

    session.loop { !remote_exists?(session) }

    yield session
    session.close unless session.closed?
  ensure
    session.shutdown unless session.closed?
  end

  private

  def db_host
    db_config[:host]
  end

  def db_port
    db_config[:port]
  end

  def db_config
    @db_config ||= ActiveRecord::Base.connection.instance_variable_get(:@config)
  end

  def ssh_options
    {:keys => [
      File.expand_path('../../../keys/key', __FILE__)
    ]}
  end

  def remote_exists?(session)
    session.forward.active_remotes.include?(
      [@configuration.database_port, '0.0.0.0']
    )
  end
end
```
assistant