class Async::HTTP::Body::Remainder

def close(error = nil)
	# We can't really do anything in this case except close the connection.
	@stream.close
	
	super
end

def empty?
	@stream.closed?
end

def initialize(stream)
	@stream = stream
end

def inspect
	"\#<#{self.class} #{@stream.closed? ? 'closed' : 'open'}>"
end

def join
	read
end

def read
	@stream.read_partial
end