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 unless @stream.closed? end