Monitoring HTTP

This is a snippet I pulled from tap-http. It is from an older library, Prosperity. Basically this shows where to hook into the Net::BufferedIO to monitor the progress of an HTTP request that sends updates.

Ignore the Acts::Monitorable and observe where its tick_monitor method is used.

module Net
  class HTTP
    attr_reader :socket
  end

  class BufferedIO
    include Prosperity::Acts::Monitorable

    private

    def rbuf_fill
      tick_monitor
      timeout(@read_timeout) {
        @rbuf << @io.sysread(1024)
      }
    end
  end
end