public void process(Iterator<I> functions, Consumer<R> consumer) {
		this.resultConsumer = Objects.requireNonNull(consumer);
		addAll(functions);
	}
Adds all items to the queue for processing.  The results will be passed to the given consumer
as they are produced.

@param functions the functions to process
@param consumer the results consumer
Ghidra/Features/Decompiler/src/main/java/ghidra/app/util/DecompilerConcurrentQ.java