Class AbstractForEachOperation<Original,​K,​V,​S extends BaseStream<V,​S>>