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

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

def initialize(stream, length)

def initialize(stream, length)
	super(length)
	
	@stream = stream
end

def read

def read
	if chunk = super
		# If we read a chunk fron the stream, we want to extend the window if required so more data will be provided.
		@stream.request_window_update
	end
	
	return chunk
end