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