class Async::HTTP::Body::Remainder

def empty? 

def empty?
	@stream.closed?
end

def initialize(stream) 

def initialize(stream)
	@stream = stream
end

def inspect 

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

def join 

def join
	read
end

def read 

def read
	@stream.read_partial
end

def stop(error) 

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