class Input < ::Protocol::HTTP::Body::Readable

parameter　channel　Channel

The input channel.

parameter　headers　Protocol::HTTP::Headers

The request headers to receive trailers.

parameter　metadata　Hash

The original body metadata.

def initialize(channel, headers, metadata)
	@channel = channel
	@headers = headers
	@length = metadata[:length]
	@stream = metadata[:stream]
	@finished = false
	@closed = false
end

attribute　Integer | Nil

The original body length.

returns　Boolean

Whether the original body preferred streaming.

def stream?
	@stream
end

returns　Boolean

Whether the body has finished.

def empty?
	@finished
end

returns　String | Nil

The next chunk, or nil after body completion.

def read
	return nil if @closed || @finished
	
	loop do
		message = @channel.read
		raise ClosedError unless message
		
		type, payload = message
		
		case type
		when :chunk
			return payload
		when :trailers
			apply_trailers(payload)
		when :end
			@finished = true
			return nil
		when :error
			@finished = true
			raise RemoteError.new(payload)
		else
			raise ClosedError, "Unexpected input event: #{type.inspect}!"
		end
	end
end

def close(error = nil)
	return if @closed
	
	@closed = true
	@channel.close_read unless @finished
end