Class AbstractPipeConsumer<T>