class Protocol::HTTP::Body::Buffered

def self.for(body)
	chunks = []
	
	body.each do |chunk|
		chunks << chunk
	end
	
	self.new(chunks)
end

def self.wrap(body)
	if body.is_a? Readable
		return body
	elsif body.is_a? Array
		return self.new(body)
	elsif body.is_a?(String)
		return self.new([body])
	elsif body
		return self.for(body)
	end
end

def close(error = nil)
	@chunks << nil
end

def empty?
	@index >= @chunks.length
end

def finish
	self
end

def initialize(chunks = [], length = nil)
	@chunks = chunks
	@length = length
	
	@index = 0
end

def inspect
	"\#<#{self.class} #{@chunks.count} chunks, #{self.length} bytes>"
end

def length
	@length ||= @chunks.inject(0) {|sum, chunk| sum + chunk.bytesize}
end

def read
	if chunk = @chunks[@index]
		@index += 1
		
		return chunk.dup
	end
end

def rewind
	@index = 0
end

def write(chunk)
	@chunks << chunk
end