class Output < ::Protocol::HTTP::Body::Readable

parameter　execution　Execution

The owning execution.

parameter　headers　Protocol::HTTP::Headers

The response headers to receive trailers.

parameter　metadata　Hash

The remote response body metadata.

def initialize(execution, headers, metadata)
	@execution = execution
	@headers = headers
	@length = metadata[:length]
	@stream = metadata[:stream]
	@mode = nil
	@finished = false
end

attribute　Integer | Nil

The remote response body length.

returns　Boolean

Whether the remote body prefers direct streaming.

def stream?
	@stream
end

returns　Boolean

Whether the remote body has finished.

def empty?
	@finished
end

def read
	return nil if @finished
	
	start(:read)
	return read_output
end

def call(stream)
	unless stream?
		return super(stream)
	end
	
	start(:stream)
	input_task = @execution.stream_input(stream)
	error = nil
	
	begin
		while chunk = read_output
			stream.write(chunk)
			stream.flush
		end
	rescue => error
		@execution.cancel(error)
		raise
	ensure
		input_task&.cancel
		stream.close(error)
		@execution.finish unless error
	end
end

def close(error = nil)
	unless @finished
		@finished = true
		@execution.cancel(error)
	end
end