fibers.rb

# Net::HTTPResponse streaming for use in Rack apps with Fibers!

def read_body # Net::HTTPResponse#read_body
  yield "foo"; yield "bar"; yield "baz"
end

class R # A Rack Streaming response
  def initialize
    @f = Fiber.new do
      read_body do |chunk| # Net::HTTPResponse#read_body
        sleep(0.5)
        Fiber.yield(chunk)
      end
    end
  end

  def each
    while x = @f.resume
      yield x
    end
  end
end

R.new.each do |chunk|
  puts chunk # Streaming!
end