class Protocol::Rack::Body::Streaming::Output

def close
	@fiber = nil
end

def initialize(input, block)
	stream = ::Protocol::HTTP::Body::Stream.new(input, self)
	@fiber = Fiber.new do
		block.call(stream)
		@fiber = nil
	end
end

def read
	@fiber&.resume
end

def write(chunk)
	Fiber.yield(chunk)
end