gistfile1.rb

module HealthReport
  module LogStreamer

    def stream(url, timeout)
      Timeout::timeout(20) do
        EventMachine.run  do
          EventMachine::PeriodicTimer.new(15) { out << "\0" }
          http = EventMachine::HttpRequest.new(url, keepalive: true, connection_timeout: 0, inactivity_timeout: 0).get
          buffer = ""
          http.stream do |chunk|
            buffer << chunk
            yield buffer
          end
        end
      end
    end

  end
end