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

def process_data(frame)

@returns [String] The unpacked data.
@parameter frame [Protocol::HTTP2::DataFrame] The data frame to process.
Process an incoming DATA frame and write it to the input body. 
def process_data(frame)
	data = frame.unpack
	
	if input = @input
		unless data.empty?
			input.write(data)
		end
		
		if frame.end_stream?
			input.close_write
		end
	else
		# The application has closed the input, so discard incoming data while maintaining flow control for the stream.
		request_window_update
	end
	
	return data
rescue ::Protocol::HTTP2::ProtocolError
	raise
rescue # Anything else...
	send_reset_stream(::Protocol::HTTP2::Error::INTERNAL_ERROR)
end