class Async::HTTP::Protocol::HTTP2::Stream

def process_headers(frame)
	if frame.end_stream? && @headers
		self.receive_trailing_headers(super, frame.end_stream?)
	else
		@headers ||= ::Protocol::HTTP::Headers.new
		self.receive_initial_headers(super, frame.end_stream?)
	end
	
	# TODO this might need to be in an ensure block:
	if @input and frame.end_stream?
		@input.close($!)
		@input = nil
	end
rescue ::Protocol::HTTP2::HeaderError => error
	Console.logger.debug(self, error)
	
	send_reset_stream(error.code)
end