O
public static interface ConcurrentPipe.OutputConsumer<O>
ConcurrentPipe
void
consume(O outputElement)
void consume(O outputElement)
outputElement