I
O
public static interface ConcurrentPipe.Processor<I,O>
ConcurrentPipe
process(I inputElement)
O process(I inputElement)
inputElement