Sha256: 01ad5af567e58cba4d316fc236f29253271a424522a30cb065e3d3b1b2b92a3a
Contents?: true
Size: 1.53 KB
Versions: 16
Compression:
Stored size: 1.53 KB
Contents
require 'rack/utils'
module Rack
# Middleware that applies chunked transfer encoding to response bodies
# when the response does not include a Content-Length header.
class Chunked
include Rack::Utils
# A body wrapper that emits chunked responses
class Body
TERM = "\r\n"
TAIL = "0#{TERM}#{TERM}"
include Rack::Utils
def initialize(body)
@body = body
end
def each
term = TERM
@body.each do |chunk|
size = chunk.bytesize
next if size == 0
chunk = chunk.dup.force_encoding(Encoding::BINARY)
yield [size.to_s(16), term, chunk, term].join
end
yield TAIL
end
def close
@body.close if @body.respond_to?(:close)
end
end
def initialize(app)
@app = app
end
# pre-HTTP/1.0 (informally "HTTP/0.9") HTTP requests did not have
# a version (nor response headers)
def chunkable_version?(ver)
case ver
when "HTTP/1.0", nil, "HTTP/0.9"
false
else
true
end
end
def call(env)
status, headers, body = @app.call(env)
headers = HeaderHash.new(headers)
if ! chunkable_version?(env[HTTP_VERSION]) ||
STATUS_WITH_NO_ENTITY_BODY.include?(status) ||
headers[CONTENT_LENGTH] ||
headers[TRANSFER_ENCODING]
[status, headers, body]
else
headers.delete(CONTENT_LENGTH)
headers[TRANSFER_ENCODING] = 'chunked'
[status, headers, Body.new(body)]
end
end
end
end
Version data entries
16 entries across 16 versions & 6 rubygems