class Async::HTTP::Protocol::HTTP2::Input

A writable body which requests window updates when data is read from it.

def close(error = nil)

@parameter error [Exception | Nil] The error that caused the input to be closed, if any.
Close the application-facing input body and notify the stream that incoming data is no longer being consumed. While local output is active, the HTTP/2 stream remains open. Once output also closes, the remaining wire stream is terminated without an error. 
def close(error = nil)
	super
	
	if stream = @stream
		@stream = nil
		stream.finish_input(self, error)
	end
end

def initialize(stream, length)

@parameter length [Integer | Nil] The expected content length.
@parameter stream [Stream] The HTTP/2 stream to read from.
Initialize the input body. 
def initialize(stream, length)
	super(length)
	
	@stream = stream
	@remaining = length
end

def read

@returns [String | Nil] The next chunk, or `nil` if the body is complete.
Read the next chunk of data, requesting window updates as needed. 
def read
	if chunk = super
		# If we read a chunk from the stream, we want to extend the window if required so more data will be provided.
		@stream&.request_window_update
	end
	
	# We track the expected length and check we got what we were expecting.
	if @remaining
		if chunk
			@remaining -= chunk.bytesize
		elsif @remaining > 0
			raise EOFError, "Expected #{self.length} bytes, #{@remaining} bytes short!"
		elsif @remaining < 0
			raise EOFError, "Expected #{self.length} bytes, #{@remaining} bytes over!"
		end
	end
	
	return chunk
end