class Async::HTTP::Protocol::HTTP2::Stream::Buffer
def initialize(stream, body, task: Task.current)
def initialize(stream, body, task: Task.current) @stream = stream @body = body @remainder = nil @window_updated = Async::Condition.new @task = task.async(&self.method(:passthrough)) end