Streaming example with CURB

example.rb

require 'sinatra/base'

server = Thread.new do
  class Example < Sinatra::Base
    set :server, :thin
    get '/' do
      stream(:keep_open) do |out|
        5.times {
          out << "streaming output\n"
          sleep 1
        }
        out.close
      end
    end
    run!
  end
end

sleep 2

# CURB client
require 'curb'

curl = Curl::Easy.new
curl.url = 'http://localhost:4567/'
curl.on_body do |data| 
  puts ">> #{data}"; data.size 
end
curl.http(:GET)

server.exit

That works with Typhoeus out of the box:

Typhoeus.get("localhost:4567/").body
#=> "streaming output\nstreaming output\nstreaming output\nstreaming output\nstreaming output\n"

Edit: oh. You don't see the single lines... do you need that? Ethon might me be suited then...

Yes I'm interested in every single line as soon as it arrives. My use case is basically a long running server process that streams e.g. log output.