class Async::HTTP::Body

def close
	self.enqueue(nil)
end

def closed?
	@closed
end

def each
	return if @closed
	
	while chunk = self.dequeue
		yield chunk
	end
	
	@closed = true
end

def initialize
	super
	
	@closed = false
end

def read
	buffer = Async::IO::BinaryString.new
	
	self.each do |chunk|
		buffer << chunk
	end
	
	return buffer
end

def write(chunk)
	self.enqueue(chunk)
end