Contents

# This Sinatra application must be run with mongrel
# or possibly with unicorn for the serve action to work properly.
# See http://efreedom.com/Question/1-3669674/Streaming-Data-Sinatra-Rack-Application

require 'sinatra'

get '/wait/:time' do |time|
  time = time.to_i
  sleep(time)
  "Slept #{time} at #{Time.now}"
end

# http://efreedom.com/Question/1-3027435/Way-Flush-Html-Wire-Sinatra
class Streamer
  def initialize(time, chunks)
    @time = time
    @chunks = chunks
  end
  
  def each
    @chunks.each do |chunk|
      sleep(@time)
      yield chunk
    end
  end
end

get '/serve/:chunk_size/every/:time/for/:count' do |chunk_size, time, count|
  chunk_size, time, count = chunk_size.to_i, time.to_i, count.to_i
  chunk = 'x' * chunk_size
  chunks = [chunk] * count
  Streamer.new(time, chunks)
end

Version data entries

45 entries across 45 versions & 4 rubygems

Version	Path
curb-1.0.9	tests/timeout_server.rb
curb-1.0.8	tests/timeout_server.rb
curb-1.0.7	tests/timeout_server.rb
curb-1.0.6	tests/timeout_server.rb
curb-1.0.5	tests/timeout_server.rb
curb-1.0.4	tests/timeout_server.rb
curb-1.0.3	tests/timeout_server.rb
curb-1.0.2	tests/timeout_server.rb
curb-1.0.1	tests/timeout_server.rb
curb-1.0.0	tests/timeout_server.rb
curb-0.9.11	tests/timeout_server.rb
curb-0.9.10	tests/timeout_server.rb
curb-0.9.9	tests/timeout_server.rb
curb-0.9.8	tests/timeout_server.rb
curb-0.9.7	tests/timeout_server.rb
curb-0.9.6	tests/timeout_server.rb
curb-0.9.5	tests/timeout_server.rb
curb-0.9.4	tests/timeout_server.rb
curb-0.9.3	tests/timeout_server.rb
curb-0.9.2	tests/timeout_server.rb