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