class Async::HTTP::Body

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